Kafka的多任务线程消费测试

代码: package com.weichai.kafka; import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; /** * 消费者的线程执行 * @author lhy * @date 2018.10.09 */ public class Consumer implements Runn

>>阅读原文<<