[WIP] Kafka and MQTT support in Python