Using MQTT with Flow Director

Integration with Ease.

MQTT stands for MQ Telemetry Transport. It is a publish/subscribe, extremely simple and lightweight messaging protocol, designed for constrained devices and low-bandwidth, high-latency or unreliable networks. It can be easily integrated into Flow Director and with any other messaging system.

Get Flow Director

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.

Share this page:
Data Privacy

Copyright ©2023 Edge Broker GmbH. All rights reserved.

Some icons by Icons8.