Data pipeline POC

more to come ...

Troubleshouting

if the schema-registry fails to start, then execute:

docker-compose exec kafka /bin/bash
kafka-topics --alter --config cleanup.policy=compact --topic _schemas --zookeeper zk
docker-compose restart schema-registry