Spring kafka demos

• kafka-simple - request-response simple demo.
• kafka-producer - app producing messages.
• kafka-consumer - app consuming messages.
• kafka-sync-demo - synchronizing producers and consumers (cluster).

Compile & Run

gradle clean build
java -jar kafka-simple/build/libs/kafka-simple-1.0.0-SNAPSHOT.jar --server.port=8080
java -jar kafka-producer/build/libs/kafka-producer-1.0.0-SNAPSHOT.jar --server.port=8081
java -jar kafka-consumer/build/libs/kafka-consumer-1.0.0-SNAPSHOT.jar --server.port=8091 --spring.kafka.consumer.group-id=group-01

Download and Start kafka locally

Download kafka and unzip

tar -xzf kafka_2.13-2.6.0.tgz
cd kafka_2.13-2.6.0

#start zookeeper and kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

#create topic service-requests
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic simple-test-topic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4 --topic prod-con-test-topic

Start locally with docker-compose

See original docker-compose.yml file or kafka on hub.docker.io.

docker-compose up -d
docker-compose down