我运行了一个MQTT代理和一个Kafka代理，我使用了kafka-connector：，配置如下：connector.class=com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector` WITHKEY(id)c
浏览 0提问于2018-11-19得票数 1
我想要在MQTT队列和Kafka队列之间创建一座桥，为此我想使用kafka connect，但是要连接到MQTT队列，我需要使用一个特定的标识符，但我找不到在哪里指明这一点，因为我在kafka mqtt连接器文档https://docs.confluent.io/kafka-connect-mqtt/current/mqtt
浏览 49提问于2021-04-19得票数 0
我正在尝试订阅一个带有kafka的mqtt主题，为此我使用了以下连接器：。我按照上面描述的步骤做了一些修改，一切似乎都很顺利。但是，当我启动连接器时，我会得到一个 (屏幕截图)，连接器就会停止。它似乎来自IMqttMessageListener，但我不知道如何解决这个问题。connector.class : be.jovacon.kafka.connect.MQTTSourceConnector
mqtt.broker :
浏览 0提问于2020-05-10得票数 2
回答已采纳
1回答
我试图使用镜头MQTT源连接器与汇合卡夫卡v5.4。(id)connect.mqtt.service.quality=1connect.mqtt.hosts=tc
浏览 4提问于2020-05-31得票数 1
回答已采纳
1回答
我使用的是connectors 5.3.1，我在分布式模式下定义了两个不同的mqtt源连接器，使用："value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter",
&q
浏览 1提问于2019-12-04得票数 0
回答已采纳
1回答
from or stored into Kafkakey.converter我们的输入是python中的一个字符串，类似于： {'id': 42, 'cost': 4000} 有什么建议如何配置属性文件吗？编辑:根据需要，我提供了更多信息，我们转移到分布式模式，使用3个代理的集群，我们按如下方式启动连接
浏览 29提问于2021-09-23得票数 0
:1883kafka.topics=mqtt.=at.grahsl.kafka.connect.mongodb.processor.id.strategy.BsonOidStrategy
mongodb.post.processor.chain{id=MQTT-source-0} Source task finished initialization and start (org.apache.kafka
浏览 1提问于2018-12-25得票数 0
我需要将传入的传感器数据从Mqtt代理传输到Kafka代理。做这件事最有效的工具是什么？有没有能高效提供Kafka桥插件的中介？
浏览 31提问于2017-08-16得票数 2
=io.confluent.connect.mqtt.MqttSinkConnectortasks.max=1topics=mqtt 当我运行Kafka-connect时，它失败并显示以下消息 [2021-07-22 17:35:37,565] ERROR WorkerSinkTask{id=
浏览 32提问于2021-07-23得票数 0
回答已采纳
我在浏览所需的技术时，发现了两个MQTT & Apache Kafta。在我看来，两者似乎都在以相同的方式做同样的事情(在订阅和发布主题方面)。
我听说MQTT很适合手机，因为它很轻？
浏览 3提问于2016-05-23得票数 42
现在我正在尝试从mqtt消息连接到kafka (实际上是kafka中的spark streaming )和Spark-2.1.0，Kafka - 0.10.1.1 client = new MqttClient(brokerUrl, MqttClient.generateClientId, persistence)
client.connect(key.deserializer" -> class
浏览 18提问于2017-02-11得票数 0
回答已采纳
我试着用lenses.io反应堆来消耗从MQTT到Kafka的信息。流反应器的最新版本sh-4.4$ kafka-topics --versionkafka-connect-mqttkafka-broker-1:19093
CONNECT_GROUP_ID: 'kafka
浏览 5提问于2022-04-13得票数 2
回答已采纳
5回答
如何通过kafka作为消息代理来使用mqtt协议？客户端(android/ios/桌面、java应用程序等)将使用mqtt phao客户端库来生成和消费消息，这些库有不同语言的版本，使用kafka作为消息代理。
有什么建议吗？
浏览 6提问于2015-10-28得票数 7
1回答
我正在从事一个IoT项目，该项目使用MQTT协议将传感器数据从嵌入式设备传输到应用程序。为此我创造了，
现在，我需要的是使用django的Kafka消息，保存到DB，然后通过websockets将这些数据推送到客户端。但对于如何使用</e
浏览 2提问于2022-02-27得票数 1
1回答
我有一个将Kafka流数据分发给MQTT主题的系统。阿帕奇骆驼路线看起来是这样的：java.lang.IllegalStateE
浏览 4提问于2022-05-11得票数 0
回答已采纳
我使用卡夫卡连接创建一个MQTT卡夫卡连接，我把所有卡夫卡MQTT连接器特定的jar从汇流网站下载到"/data“文件夹。并相应地更新"connect-standalone.properties“文件以反映插件路径，即当我运行卡夫卡连接/config/connect-mqtt-source.
浏览 0提问于2019-07-18得票数 0
我正在尝试从ksql中使用下面的命令，并获得以下错误confluent - Confluent CLI
Git Refce, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqttce, type=source,
浏览 14提问于2022-09-14得票数 0
我使用aREST访问我的NODEMCU，但是它在串行监视器上显示"Attempting connection...failed，rc=-4 \f25 5秒重试“ 我的代码： // Control ESP8266to device rest.set_name("relay_anywhere");
WiFi.beginWiFi connected"
浏览 580提问于2019-10-03得票数 1
回答已采纳
我使用的是paho-mqtt c++库。我使用的是异步通信模型。我已经创建了Callaback类并实现了必要的方法。我还创建了一个包含发送和接收队列的mqtt_client类，以及几个方法，如connect、send_data、get_recieved_data等。bool connect(void){ callb
浏览 60提问于2019-09-13得票数 2
无法使用RabbitMQ mqtt客户端连接到我的node.js服务器(启用mqtt适配器)。两者之间是否存在兼容性问题？我可以使用bluerhinos PHP库连接到队列，因此我知道队列名和主机名等都是正确的，并且消息正在被正确检索。Node.js应用程序
var mqttClient = mqtt.connect('mqtt:
浏览 0提问于2015-05-04得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
