Added a Kafka consumer