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
Consumer exception

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();

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

Navneet Sharma