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.
Apache Kafka is a data streaming platform connecting and exchanging data between enterprise systems. However, Kafka 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 Kafka integration. EMQX makes MQTT and Kafka 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 Kafka'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 Kafka seamless and flexible.
With the built-in data bridge and rule engine, EMQX can consume from and produce message batches to Kafka.
EMQX can write up to 1 million MQTT messages per second to Kafka thanks to the asynchronous and batch processing mechanism.
EMQX can automatically discover the partition scale-ups in Kafka without having to re-configure or restart, making it easy to scale up the capacity as your business grows.
With the built-in Flow Designer, you can extract, filter, enrich, and transform IoT data and write to a specific Kafka topic without writing code.
With just a few clicks, you can filter, extract, transform, and ingest your IoT data into Kafka using EMQX’s rule engine and flow designer.Learn More →