This example shows how to receive messages from any MQTT broker and pass it to Apache Kafka. A consumer is created on any topic of the connected MQTT broker and the messages are sent to the local SwiftMQ router to topic inboundtopic. This step is required to automatically convert the MQTT message into a JMS message. These messages are received from the inboundtopic and sent to a Kafka topic. Because a flow runs inside a SwiftMQ router which provides a MQTT broker itself, you could also directly connect your MQTT clients which can send to the inboundtopic. This would save the step to go through an external MQTT broker.