Simple async example with python and kafka run kafka with docker-compose up --build run consumer with python3 consumer.py run producer with python3 producer.py Enjoy logs in terminal