Contains files for running kafka and zookeeper in containerized environment and its basic demonstration using kafka-python
producer.py
- simulates a simple order with its details
consumer.py
- simulates a order/transaction validation service
- Clone this repo using
git clone https://github.com/adhirajpandey/kafka-setup
andcd
into it. docker compose up
to run essential kafka containers.pip install -r requirements.txt
to install the requiremnts.python3 consumer.py
andpython3 producer.py
to run both simulation scripts.