Overview

Produce messages to and consume messages from a Kafka cluster using Confluent Python Client for Apache Kafka.

Install requirements

pip3 install -r requirements.txt

Run the file

python3 <file>.py

Exercises

Fill in the commented out code in the producer and consumer files. Answers are in the answers branch