kafka（4）分区消费模型和组消费模型

分区消费模型 描述代码 main() 获取分区的size for index =0 to size create thread(or process) consumer(Index) 第index个线程(进程) consumer(index) 创建到kafka broker的连接: KafkaClient(host,port) 指定消费参数构建consumer: SimpleConsumer(to

>>阅读原文<<