Kafka Consumer

Question

@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()是不是会阻塞线程，我跟踪到这里程序不再往下执行了。

Answer 1

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

Answer 2

是的 是会阻塞的 就是一直在监听  只要producer发数据了 consumer就能直接拿到数据