-
Build all
$ mvn package
-
Create a docker image of MQTT-Kafka Bridge
$ mvn -f pom-docker.xml exec:exec@docker-build
-
Run a docker image (example)
$ docker run -d --rm --name mqtt-kafka-bridge \ -e mp.messaging.connector.helidon-kafka.bootstrap.servers=kafka-broker:9092 \ -e mp.messaging.incoming.mqtt-sub.server=mqtt-broker \ -e mp.messaging.incoming.mqtt-sub.topic=some-topic-on-mqtt \ -e mp.messaging.outgoing.kafka-pub.topic=some-topic-on-kafka \ -e mp.messaging.outgoing.mqtt-post.topic=another-topic-on-mqtt \ -e mp.messaging.outgoing.kafka-post.connector=null \ -v $(pwd)/logging-debug.properties:/helidon/logging-debug.properties \ -p 8181:8181 \ mqtt-kafka-bridge java \ -Djava.util.logging.config.file=logging-debug.properties \ -jar mqtt-kafka-bridge.jar
tkote / mqtt-connector-kafka-bridge Goto Github PK
View Code? Open in Web Editor NEWMQTT Connector / MQTT-Kafka Bridge / REST POST Tools, based on MicroProfile Reactive Messaging