lianetm commented on code in PR #16974:
URL: https://github.com/apache/kafka/pull/16974#discussion_r1728832826
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManager.java:
##########
@@ -59,7 +59,7 @@ public interface RequestManager {
* <em>all</em> request managers is critical to ensure that we can
complete as many of the consumer's shutdown
* tasks as possible within the user-provided timeout.
*/
- default PollResult pollOnClose() {
+ default PollResult pollOnClose(long currentTimeMs) {
Review Comment:
makes sense, done.
--
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
