cb_kafka_consumer
