multiprocess_kafka_consumer
