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 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 specified in the last call of
KafkaConsumer#seek instead of the latest offset. Seems the comment is not
correct. What do you say? Any comments are welcomed.
