Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Consumer exception


Copy link to this message
-
Re: Consumer exception
yes of course, the code snippet which i posted is from the
kafka.examples.Consumer
only.

Its not modified to use MessageAndMetadata.

Has it been changed in last week?

Thanks,
Navneet Sharma

On Tue, Jun 5, 2012 at 8:12 PM, Jun Rao <[EMAIL PROTECTED]> wrote:

> 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
> <[EMAIL PROTECTED]>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
> >
>