How to connect MQTT broker with golang kafka

#1

I have an MQTT topic that produces a message every 5 seconds. I want to write that message to Kafka’s topic. is there is an MQTT adapter for direct connection to the Kafka?. I currently use the MQTT package is “eclipse/paho.mqtt.golang”. I didn’t see any good examples right now and could you please guide me?

#2

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.