Kirk True created KAFKA-20131:
---------------------------------
Summary: SubscriptionState endOffsetRequested is left set when
LIST_OFFSETS call fails
Key: KAFKA-20131
URL: https://issues.apache.org/jira/browse/KAFKA-20131
Project: Kafka
Issue Type: Bug
Components: clients, consumer
Affects Versions: 3.9.1
Reporter: Kirk True
Assignee: Kirk True
Fix For: 4.3.0
When {{Consumer.currentLag()}} is called,
{{SubscriptionState.requestPartitionEndOffset()}} is called, which sets a
per-partition flag named {{endOffsetRequested}}. This flag is later cleared by
{{SubscriptionState.updateLastStableOffset()}}/{{SubscriptionState.updateHighWatermark()}}
when a successful {{LIST_OFFSETS}} call is received. However, if the partition
has an error code in the response, or the {{LIST_OFFSETS}} call itself fails,
neither update method is called, and {{endOffsetRequested}} remains set. The
problem is, on _any subsequent_ call to {{Consumer.currentLag()}}, the logic
will see that {{endOffsetRequested}} is already set, and the offset request
will be silently ignored.
The fix is to ensure that {{endOffsetRequested}} is cleared out even on failure
cases.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
