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 Threaded View
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:
 
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