mqtt-to-kafka-bridge - consume, (etl/mirror), produce

Intro

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.

How to use?

Just check out the example here it also gives you description on the configuration options. You can find the sample configuration here.

Info

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.

Maintainer

Build with ❤️ 🍕 and ☕️ by nodefluent