https://python.elitedev.in/python/build-real-time-data-pipelines-apache-kafka-python/