examples

Run live demo

1.Run full kafka environment

docker-compose up -d

Visit localhost:3030 to play with the nice fast-data-dev dashboard

2.Install requirements

pip install kafka-python confluent_avro

3.Run consumer app in tab 1

python consumer.py

4.Run producer app in tab 2

python producer.py

5.Play with the schema and the data to test different scenarios

Credit:

• Data used in this examples are taken from landoop/sample-data