Integration with Ease.

Get Flow Director

MQTT Integration

Integration with MQTT: Seamlessly Pass MQTT Messages to Apache Kafka

Discover how Flow Director enables smooth transfer of MQTT messages to Apache Kafka.

Integration Details:

  • MQTT Message Handling:
    • Retrieve messages from any MQTT broker.
    • Redirect these messages to Apache Kafka.
  • Consumer Creation:
    • Establish a consumer on a specific topic of the connected MQTT broker.
  • Message Forwarding to SwiftMQ Router:
    • Channel messages to the local SwiftMQ router's topic named inboundtopic.
    • This intermediary step ensures automatic conversion of MQTT messages into JMS messages.
  • SwiftMQ Router Processing:
    • Retrieve JMS messages from the inboundtopic.
    • Forward these JMS messages to a Kafka topic.
  • Alternative Configuration:
    • Since Flow Director operates within a SwiftMQ router that functions as an MQTT broker, direct connection of MQTT clients to the inboundtopic is possible.
    • This bypasses the need for an external MQTT broker, reducing complexity.

Efficiently harness Flow Director's capabilities to seamlessly integrate MQTT and Kafka for message transfer, streamlining your messaging infrastructure.

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.

Share this page