What is this app?

Spring Cloud Stream Kafka adaptation of the confluent blog example

Running the app:

docker-compose up -d

./mvnw clean package

java -jar target/kafka-stream-join-0.0.1-SNAPSHOT.jar

Produce a sample data using Producers application few times.

Play time, run the kafka consumer:

docker exec -it kafka-stream /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic output-topic --key-deserializer org.apache.kafka.common.serialization.StringDeserializer --value-deserializer org.apache.kafka.common.serialization.LongDeserializer --property print.key=true --property key.separator="-"