A simple MSB to Apache Kafka Connector

This application writes MSB events into Kafka and publishes Kafka messages as MSB events to the Manufacturing Service Bus.

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]

• subscribed-kafka-topics = kafka topics which will be subscribed (separated by a ; )

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_msb_connector-0.0.1-SNAPSHOT.jar

Usage with Docker

• Docker Hub https://hub.docker.com/r/arthurgrigo/simple-kafka-msb-connector

• Run (edit environment variables to your needs!) : docker run -d -t -i -e KAFKA_HOST='KAFKA' -e KAFKA_PORT=9092 -e KAFKA_CLIENT_ID='testing-kafka-producer-1' -e SUBSCRIBED_KAFKA_TOPICS='topicA;topicB;topicC' --name simple-kafka-msb-connector arthurgrigo/simple-kafka-msb-connector:latest

Usage with Docker-Compose

Standalone

• docker-compose.yml

• Run: docker-compose up -d

License

See LICENSE file for License