Kafka, mail # user - Re: 0.8 behavior change: consumer "re-receives" last batch of messages in a topic? - 2013-03-13, 19:15
 Search Hadoop and all its subprojects:

Switch to Plain View
+
Hargett, Phil 2013-03-13, 19:00
+
Chris Curtin 2013-03-13, 19:14
Copy link to this message
-
Re: 0.8 behavior change: consumer "re-receives" last batch of messages in a topic?
In 0.8, the iterator over the data returned in the FetchResponse is over
MessageAndOffset. This class has a nextOffset() API, which is the offset of
the next message in the message set. So, the nextOffset() value returned on
the last message in the message should be used as the fetch offset in the
following fetch() call to Kafka.

Thanks,
Neha
On Wed, Mar 13, 2013 at 11:49 AM, Hargett, Phil <
[EMAIL PROTECTED]> wrote:
 
+
Chris Curtin 2013-03-13, 19:42
+
Neha Narkhede 2013-03-13, 19:58
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB