Skip to content

Dockerized Kafka Streams application, with Github Actions and Kafka Streams Test.

Notifications You must be signed in to change notification settings

szczepanja/kafka-streams-dockerized

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

19 Commits
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

kafka-streams-dockerized

Dockerized Kafka Streams application using Docker Compose.

How to run?

  1. Run sbt docker

  2. Open terminal in master branch of this project and run docker compose up -d (-d stands for ** detached** mode).

  3. Run Kafka Console Producer using this command:

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

  4. In master branch of this project in another terminal run Kafka Console Consumer using this command:

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

    • Now produce message from Producer to Consumer and wait for the event in Consumer terminal
  5. You can also check out the Confluent Control Center on localhost:9021

    • Navigate to: Topics > output > Messages and produce message from here. The output will be available on your Consumer terminal.

This project includes GitHub Actions exercise.

About

Dockerized Kafka Streams application, with Github Actions and Kafka Streams Test.

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages