kafka-streams-docker

The example of a dockerized Kafka Streams application using docker-compose. It runs the WordCount demo application that is included in the Apache Kafka documentation.

Contents

• 1. What you need
• 2. How to run
• 3. FAQ

1. What you need

• Docker

• Scala

• Sbt

2. How to run

1. Execute command

sbt docker

1. In the docker folder, open the terminal and execute the command

docker-compose up -d

1. If you want to produce input messages, after 3 minutes from starting the application execute the command:

docker-compose exec broker kafka-console-producer --topic text-topic --bootstrap-server localhost:9092

1. If you want to consume output messages, execute the command:

docker-compose exec broker kafka-console-consumer --topic count-topic --from-beginning --bootstrap-server localhost:9092

1. To shut down docker application, execute the command:

docker-compose down

3. FAQ

1. If the service damian-app crushes, execute the command:

docker-compose run damian-app

💡	Check if Kafka Broker and Zookeeper are running