Instructions update docker-compose.yaml with your IP start kafka docker-compose up -d pip install kafka-python start consumer python consumer.py start producer python producer.py