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.
On Wed, Mar 13, 2013 at 11:49 AM, Hargett, Phil <
[EMAIL PROTECTED]> wrote: