ht. I would have been thinking it that way Thank
you.
发件人: Michal Borowiecki <michal.borowie...@openbet.com>
发送时间: 2017年4月13日 17:02
收件人: dev@kafka.apache.org
主题: Re: Invoking KafkaConsumer#seek for the same partition
Sounds to me the comment is imprecise
Oh My! yes, you are right. I would have been thinking it that way Thank
you.
发件人: Michal Borowiecki <michal.borowie...@openbet.com>
发送时间: 2017年4月13日 17:02
收件人: dev@kafka.apache.org
主题: Re: Invoking KafkaConsumer#seek for the same partition
Sounds
Sounds to me the comment is imprecisely phrased but was meant to
indicate the behaviour you are describing.
Perhaps instead of "the latest offset", it should say, "the offset used
in the latest seek" to make it super-clear.
Cheers,
Michal
On 13/04/17 08:28, Hu Xi wrote:
Hi guys,
The
Hi guys,
The comments for KafkaConsumer#seek says “If this API is invoked for the same
partition more than once, the latest offset will be used on the next poll()”.
However, I tried a couple of times, and it turned out that the next poll could
always read records from the offset which was
