saurabhchopade opened a new pull request, #21489: URL: https://github.com/apache/kafka/pull/21489
Fixes KAFKA-20131. When ListOffsets fails while currentLag() is trying to fetch the end offset, the partition state kept endOffsetRequested=true. That prevented subsequent currentLag() calls from issuing another ListOffsets request. This patch clears endOffsetRequested on request failure so retries can proceed, and adds a focused unit test in SubscriptionStateTest. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
