In trunk, the iterator api has changed to KafkaStream<MessageAndMetadata>. Take a look at kafka.examples.Consumer in java-examples.
Thanks, Jun On Tue, Jun 5, 2012 at 6:33 AM, navneet sharma <navneetsharma0...@gmail.com>wrote: > Hi, > > I downloaded the latest code from trunk last week and i was trying this > snippet as given in examples. > > > 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())); > } > > But its giving following error: > Type mismatch: cannot convert from KafkaStream<MessageAndMetadata> to > KafkaStream<Message> at > ConsumerIterator<Message> it = stream.iterator(); > > Can you please tell how to run the above snippet with MessageAndMetadata? > And also please tell whether it requires any code changes in producer as > well? > > Thanks, > Navneet Sharma >
