This code is the companion of the blog post Kafka as a coordinator
This project uses Docker to create a cluster of 3 microservices that consume from a Kafka topic using the Kafka Streams API.
The main processing function is here.
Docker should be installed.
To run:
docker-compose up -d && docker-compose logs -f our-service our-service2 our-service3
Once the environment has been started, you have to add some commands with:
curl --data "command-key=key1&command=open the door" -X POST http://localhost:3004/run-command
To get rid of all:
docker-compose down --rmi all --remove-orphans
docker image rm pandeiro/lein:2.5.2 wurstmeister/kafka:0.10.1.0-1