一直不理解这里的topicCountMap是什么意思。kafka的High Level Consumer API设计实在是比较费解。源码又比较费解。

Map<String, Integer> topicCountMap = new HashMap<String, Integer>();
topicCountMap.put(topic, new Integer(1));
Map<String, List<KafkaStream<byte[], byte[]>>> consumerMap = consumer.createMessageStreams(topicCountMap);
List<KafkaStream<byte[], byte[]>> streams = consumerMap.get(topic);

后来查阅到这是跟线程相关的,指定消费每个topic的线程数,然后kafka consumer connector会建立对应的stream流。每个线程对应于一个KafkaStream。一个多线程消费的例子见参考文献.

参考文献:

[1] Kafka Consumer接口, http://www.cnblogs.com/fxjwind/p/3794255.html

本文版权归CXH_ME所有,原创不易,人艰不抄,转载还请注明出处,谢谢