lianetm commented on code in PR #16031:
URL: https://github.com/apache/kafka/pull/16031#discussion_r1628023841
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##########
@@ -831,10 +823,9 @@ abstract class RetriableRequestState extends RequestState {
* Complete the request future with a TimeoutException if the request
timeout has been
* reached, based on the provided current time.
Review Comment:
Let's update this to include the "if the request has been sent out at least
once and...(timeout expired)"
--
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]
