dpkp/kafka-python Architecture