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 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 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.
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.
With the built-in data bridge and rule engine, EMQX can consume from and produce message batches to Confluent.
EMQX can write up to 1 million MQTT messages per second to Confluent thanks to the asynchronous and batch processing mechanism.
EMQX can automatically detect partition scale-ups in Confluent without needing reconfiguration or restarts, ensuring scalability as your business grows.
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.
With just a few clicks, you can filter, extract, transform, and ingest your IoT data into Confluent using EMQX’s rule engine and flow designer.