Kafka的多任務線程消費測試

代碼: package com.weichai.kafka; import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; /** * 消費者的線程執行 * @author lhy * @date 2018.10.09 */ public class Consumer implements Runn
相關文章
相關標籤/搜索