Skip to content

Latest commit

 

History

History
24 lines (24 loc) · 777 Bytes

README.md

File metadata and controls

24 lines (24 loc) · 777 Bytes

KafkaTheatre

Demo link

Launch

docker stop $(docker ps -aq) && docker rm -v $(docker ps -aq)
docker-compose up -d
iex -S mix

Wait for this message to arrive

19:40:16.446 [info] client MyBroadway.Broadway.Producer_0.Client connected to localhost:29092

Once there, in the iex session, do

TestItOut.test

What it does?

Kills all running docker containers.
Tries to start pods that are required(zookeeper, kafka, schemaregistry).
The Application creates a topic `input` automatically.
When `iex` comes up, a consumer starts listening to the topic.
We use `TestItOut.test` to publish some messages which are consumed and processed by the consumer.