Bridge which consumes MQTT messages and republishes them on Kafka on the same topic - View it on GitHub