mqtt-to-kafka-bridge allows you to quickly setup a fast (about messages 2 million/sec) and lightweight (about 100 MB RAM)
bridge that subscribes to your MQTT Broker and produces messages to your Apache Kafka cluster.
You can configure routing (move messags from MQTT topics to certain Kafka topics) or filtering, as well as ETL functions
on MQTT consume, as well as on Kafka produce. You just pass everything in a simple JSON/JS config object.
Just check out the example here it also gives you description on the configuration options. You can find the sample configuration here.
The bridge spins up an http server, which can be used to check its health status http://localhost:3967/healthcheck as well as statistics http://localhost:3967/stats.
Build with ❤️ 🍕 and ☕ by nodefluent