README.md

Simple kafka consumer example

1. Run docker compose

docker-compose up

2. Install requirmeents

pip install -r requirements.txt

3. Run the code from the root folder of dam

python example/simple-kafka-consumer.py

4. Send events

Open a producer console

docker-compose exec kafka kafka-console-producer --broker-list kafka:9092 --topic test-topic-worker