Kafka Consumer

yonguo 发布于 2013/08/21 16:24
阅读 1K+
收藏 0

@FrankHui 你好,想跟你请教个问题:

Map<String, Integer> topicCountMap = new HashMap<String, Integer>();
topicCountMap.put(topic, new Integer(1));
Map<String, List<KafkaStream<Message>>> consumerMap = consumer
		.createMessageStreams(topicCountMap);
KafkaStream<Message> stream = consumerMap.get(topic).get(0);
ConsumerIterator<Message> it = stream.iterator();
while (it.hasNext()){
	log.debug(name+": "+KafkaUtils.getMessage(it.next().message()));
}

其中,如果没有数据的时候,it.hasNext()是不是会阻塞线程,我跟踪到这里程序不再往下执行了。

加载中
0
Gaischen
Gaischen
是的 是会阻塞的 就是一直在监听  只要producer发数据了 consumer就能直接拿到数据
0
xloogson
xloogson

那么如果我想做一个kafka代理的话,怎么搞,阻塞了?

返回顶部
顶部