{"repo":"ipa-digitools/simple-kafka-mqtt-connector","free":true,"listed":false,"github":"https://github.com/ipa-digitools/simple-kafka-mqtt-connector","clone":"git clone https://github.com/ipa-digitools/simple-kafka-mqtt-connector.git","description":"This application receives messages from a mqtt broker and sends the messages to a kafka cluster. Topic mapping is configurable.","language":"Java","stars":29,"topics":["iot","mqtt","kafka","big-data","java","docker","kafka-connect","kafka-connector","mosquitto-mqtt-broker","internet-of-things"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"A simple MQTT to Apache Kafka Connector Usage Prerequisites Java 8 or higher Configuration Edit the application.properties-file kafka.host = IP THROUGH WHICH THE KAFKA BROKER WILL BE REACHED [HOSTNAME IP] kafka.port = [INTEGER] kafka.client.id = [STRING] mqtt.host = IP THROUGH WHICH THE MQTT BROKER WILL BE REACHED [HOSTNAME IP] mqtt.port = [INTEGER] mqtt.client.id = [STRING] mqtt.qos = Quality of service for MQTT - [INTEGER] Allowed[0,1,2] topic.mapping = How are topics routed from MQTT to Kafka - (Separators and ;) Example mqttTopicA kafkaTopicA;mqttTopicB kafkaTopicB;mqttTopicC kafkaTopicC How to build Run: mvn clean install How to run Place the jar with dependencies and your edited application.properties-file in the same directory Open a bash or CMD in the same directory as the .jar Run: java -jar simple kafka mqtt connector-0.0.1-SNAPSHOT-jar-with-dependencies.jar Usage with Docker Docker Hub https://hub.docker.com/r/arthurgrigo/simple-kafka-mqtt-connector Run (edit enviroment variables to your needs!) : docker run -d -t -i -e KAFKA HOST='localhost' -e KAFKA PORT=9092 -e KAFKA CLIENT ID='testing-kafka-producer-1' -e MQTT HOST='localhost' -e MQTT PORT=1883 -e MQTT CLIENT ID='mqtt-client-1' -e MQTT QOS=2 -e TOPIC MAPPING='robotgroup001/robot001 test;robotgroup001/robot002 test02;robotgroup001/robot003 test03' --name simple-kafka-mqtt-connector arthurgrigo/simple-kafka-mqtt-connector:latest Usage with Docker-Compose See docker-compose-examples Standalone Stand-alone containe","default_branch":null,"files":null,"tree":[],"storefront":"/r/ipa-digitools","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/ipa-digitools/simple-kafka-mqtt-connector/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}