I am a newbie for Kafka and trying to execute the samples for 0.8 beta release from
https://github.com/apache/kafka/tree/0.8.0-beta1candidate1/examples/src/main/java/kafka/examples<https://github.com/apache/kafka/tree/0.8.0-beta1-candidate1/examples/src/main/java/kafka/examples> I tried KafkaConsumerProducerDemo and wanted to print what Consumer is consuming but its not doing anything (Consumer.java). public void run() { System.out.println(name + "(consumer)--> in run"); 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()) { // System.out.println(ExampleUtils.getMessage(it.next().message())); System.out.println(name + "(consumer)--> " + new String(it.next().message())); } Any suggestion on what I might be doing wrong here? Thanks, Menka -- Blog: http://menkag.blogspot.com "Don't let what you cannot do interfere with what you can do" - by John Wooden
