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?
