Может кафка подписаться на тему MQTT - PullRequest
Новая
       8

Может кафка подписаться на тему MQTT

0 голосов
/ 30 октября 2018

У меня есть брокер MQTT, работающий на Raspberry Pi, я могу публиковать и подписываться на темы.

Но мне бы хотелось, чтобы Кафка мог подписаться на одну или несколько тем MQTT. Может кто-нибудь помочь мне, пожалуйста?

1 Ответ

0 голосов
/ 30 октября 2018

да, вы можете сделать это.

  • Прежде всего вам необходимо настроить Kafka и zookeeper (вот официальное руководство по установке apache kafka ) (здесь официальное руководство по установке zookeeper )

  • Вам нужен плагин kafka, который будет действовать как соединитель источника MQTT (вы можете использовать этот evokly / kafka-connect-mqtt )

  • После компиляции исходного кода вам необходимо настроить плагин (указать тему MQTT, имя пользователя, пароль, IP-адрес брокера MQTT) (здесь приведен пример конфигурации )

  • Перезапустите сервер kafka и запустите соединение с источником MQTT Kafka

  • запустите потребителя kafka, который подпишется на тему kafka, которую вы настроили, и получит сообщения (вы можете обратиться к этому быстрому примеру ) или вы можете разработать своего собственного потребителя (вот пример того, как разработать ваш собственный потребитель kafka потребитель kafka в Java )
...