kafka 可以订阅 MQTT 主题吗
Can kafka subscribe on a MQTT topic
我在 raspberry pi 上有一个 MQTT 代理 运行，我可以发布和订阅主题。
但我希望 Kafka 可以订阅一个或多个 MQTT 主题。
有人可以帮我吗？
是的，你可以做到。
首先需要设置Kafka和zookeeper（这里是官方的apache kafkainstallation guide) (here is the official zookeeper installation guide）
您需要一个 kafka 插件作为 MQTT 源连接器（您可以使用这个 evokly/kafka-connect-mqtt
)
编译源码后，需要配置插件（注明MQTT主题，用户名，密码，MQTT代理IP）（这里是一个example of the configuration）
重启kafka服务器并启动Kafka MQTT源连接
- 启动一个kafka消费者订阅你配置的kafka主题并获取消息（你可以参考this quick example) or you can develop your own consumer (here is an example how to develop your own kafka consumer Kafka Consumer in Java）
我在 raspberry pi 上有一个 MQTT 代理 运行，我可以发布和订阅主题。
但我希望 Kafka 可以订阅一个或多个 MQTT 主题。 有人可以帮我吗？
是的，你可以做到。
首先需要设置Kafka和zookeeper（这里是官方的apache kafkainstallation guide) (here is the official zookeeper installation guide）
您需要一个 kafka 插件作为 MQTT 源连接器（您可以使用这个 evokly/kafka-connect-mqtt )
编译源码后，需要配置插件（注明MQTT主题，用户名，密码，MQTT代理IP）（这里是一个example of the configuration）
重启kafka服务器并启动Kafka MQTT源连接
- 启动一个kafka消费者订阅你配置的kafka主题并获取消息（你可以参考this quick example) or you can develop your own consumer (here is an example how to develop your own kafka consumer Kafka Consumer in Java）