lianetm commented on code in PR #15311: URL: https://github.com/apache/kafka/pull/15311#discussion_r1480405280
########## clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java: ########## @@ -106,6 +106,13 @@ public void onSendAttempt(final long currentTimeMs) { this.lastSentMs = currentTimeMs; } + /** + * Update the lastReceivedTime in milliseconds, indicating that a response has been received. + */ + public void updateLastReceivedTime(final long lastReceivedMs) { + this.lastReceivedMs = lastReceivedMs; Review Comment: Exactly, I did see the skip backoff logic in produce when a new leader is discovered, related to what you described. I think that the concept of "progress" here would be more abstract but still applicable, depending on the exact error we know that the action it triggers is based on some progress (send HB as new member, send HB when coord available) -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org