req-reply-kafka-consumer