Bridge which consumes MQTT messages and republishes them on Kafka on the same topic.
java -jar target/mqttKafkaBridge-0.1.0-uber.jar bridge.properties
where bridge.properties has config like
kafka = localhost:9092
kafka.batch.size = 32000
kafka.buffer.size = 128000000
mqtt = tcp://localhost:1883
topics = #
mvn package
mqttKafkaBridge uses log4j for logging, as do the Paho and Kafka libraries it uses. There is a default log4j.properties file packaged with the jar which simply prints all messages of level INFO or greater to the console. If you want to customize logging, simply create your own log4j.properties file, and start up mqttKafkaBridge as follows:
$ java -Dlog4j.configuration=file:///path/to/log4j.properties -jar mqttKafkaBridge.jar [options...]