Python Kafka Consumer From Blocks