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.