This repository has been archived by the owner on Jan 24, 2024. It is now read-only.
[BUG]The commit offset and partition data expire at the same time, and the ListOffset interface returns an incorrect result #1737
Labels
Describe the bug
The client requests the commit offset of all partitions according to offsetFetch. If the commit offset of the partition expires, the broker returns the offset of the partition as null, and the client will
auto.offset.reset
according to the configured policy, and then set the offset of the missing partition to the latest topic Or the earliest offset, get this offset and then pull the data.For example, the latest offset of a partition in topicA is 10, the oldest offset is 0, and the consumption offset of this partition is also 10. After a period of time, if the commit offset data of
__consumer_offset
expires and the client cannot get the consumption offset according to the OffsetFetch request, it will request the earliest offset of the partition according toauto.offset.reset=earliest
. If the partition data is also It has expired, and the earliest offset returned becomes 9 (one smaller than the latest offset), which should actually be 10To Reproduce
Steps to reproduce the behavior:
Expected behavior
In this scenario, the earliest and latest offsets should be the same
Screenshots
If applicable, add screenshots to help explain your problem.
Additional context
Add any other context about the problem here.
The text was updated successfully, but these errors were encountered: