我有一个运行在raspberry pi上的mqtt代理，我可以发布和订阅主题。但我希望Kafka能订阅一个或多个mqtt主题。有人能帮帮我吗？
xxhby3vn1#
是的，你能做到。首先，您需要设置kafka和zookeeper（这里是apachekafka的官方安装指南）（这里是zookeeper的官方安装指南）您需要一个kafka插件来充当mqtt源连接器（您可以使用这个evokly/kafka connect mqtt）编译源代码后，需要配置插件（指明mqtt主题、用户名、密码、mqtt代理ip）（下面是配置示例）重新启动kafka服务器并启动kafka mqtt源连接启动一个kafka consumer，它将subscibes到您配置的kafka主题并检索消息（您可以参考这个快速示例），或者您可以开发自己的consumer（下面是一个如何在java中开发自己的kafka consumer的示例）
1条答案
按热度按时间xxhby3vn1#
是的，你能做到。
首先，您需要设置kafka和zookeeper（这里是apachekafka的官方安装指南）（这里是zookeeper的官方安装指南）
您需要一个kafka插件来充当mqtt源连接器（您可以使用这个evokly/kafka connect mqtt）
编译源代码后，需要配置插件（指明mqtt主题、用户名、密码、mqtt代理ip）（下面是配置示例）
重新启动kafka服务器并启动kafka mqtt源连接
启动一个kafka consumer，它将subscibes到您配置的kafka主题并检索消息（您可以参考这个快速示例），或者您可以开发自己的consumer（下面是一个如何在java中开发自己的kafka consumer的示例）