Run Kafka

$ docker-compose up

$ ./opt/kafka/bin/kafka-topics.sh --list --zookeeper zookeeper:2181

$ ./opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 100 --topic demo

$ ./opt/kafka/bin/kafka-topics.sh --describe --topic demo --zookeeper zookeeper:2181

Run Producer

$cd Producer

$ mvn clean package

$ BROKERS=localhost:9092 TOPIC=demo java -jar target/Producer-1.0-SNAPSHOT.jar$ Type Message (type'exit' to quit)$ hello

Run Consumer

$cd Consumer

$ mvn clean package

$ BROKERS=localhost:9092 TOPIC=demo java -jar target/Consumer-1.0-SNAPSHOT.jar$ Record Key null$ Record value Product{id='001', name='Nokia 6', quantity=5, images=[wuriyanto.com/img1, wuriyanto.com/img2]}$ Record partition 49$ Record offset 0