https://levelup.gitconnected.com/building-kafka-compatible-streaming-batch-workers-in-python-8762ef769974