Skip to content

krishna1m/kafka_theatre

Repository files navigation

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.

About

understanding broadway_kafka and AvroEx

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages