Goal is to consume from a kafka topic and update a database
approaches -
- python consumer client
- connector
This is will launch kafka cluster, also the connector container and our producer container
docker-compose up
Flask server will listen on 8000 checkout req.rest, to see the payload structure
Dockerise the consumer Shifting from orm to normal sql