Streaming your IoT Data to Confluent with EMQX

Experience a hassle-free integration of MQTT and Confluent with minimal coding and setup. Say goodbye to complex processes and embrace streamlined data ingestion.

Contact an Expert →

Read the Whitepaper →

Why EMQX & Confluent

MQTT

MQTT is the de-facto standard messaging protocol for the Internet of Things (IoT), known for its lightweight and efficient design. It is perfect for connecting millions of IoT devices, even over unreliable networks, while ensuring scalability and reliability.

Confluent

Confluent is a data streaming platform connecting and exchanging data between enterprise systems. However, Confluent is not built for the IoT because it requires a stable network, consumes more resources, and only supports thousands of clients and topics.

EMQX

EMQX is a highly scalable MQTT messaging broker with built-in Confluent integration. EMQX makes MQTT and Confluent a perfect match for connecting millions of IoT devices to enterprise systems and unlocking business value from IoT data.

Full MQTT & Confluent Integration with Minimal Effort

EMQX’s out-of-the-box integration effortlessly streams MQTT messages into Confluent's data flow. With the help of EMQX's built-in SQL-based rule engine, you can easily filter, extract, enrich, and transform MQTT messages, making their ingestion into Confluent seamless and flexible.

Capabilities

Bi-directional Data Bridging

With the built-in data bridge and rule engine, EMQX can consume from and produce message batches to Confluent.

Higher Performance and Reliability

EMQX can write up to 1 million MQTT messages per second to Confluent thanks to the asynchronous and batch processing mechanism.

Automatic Capacity Expansion

EMQX can automatically detect partition scale-ups in Confluent without needing reconfiguration or restarts, ensuring scalability as your business grows.

Low-code Integration with Flows

With the built-in Flow Designer, you can extract, filter, enrich, and transform IoT data and write to a specific Confluent topic without writing code.