This is kafka implementation in golang using confluent-kafka package written in go. Bootstraped code to make it simpler to use and have producer consumer pattern. Multiple consumer reading messages from queue.
- docker
- go
Run docker compose file to have docker container for kafka broker and zookeeper.
Use Command - docker compose up
Then run main.go file for every section.
Producer main.go file produce messages Consumer1 and Consumer2 read from kafka message queue of particular topic indipendently.