diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java index 40adeec4b511f..4f7d256104bb8 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java @@ -189,7 +189,7 @@ private void reapExpiredApplicationEvents(long currentTimeMs) { * *
    *
  1. - * Iterate through the {@link RequestManager} list and invoke {@link RequestManager#pollOnClose()} + * Iterate through the {@link RequestManager} list and invoke {@link RequestManager#pollOnClose(long)} * to get the {@link NetworkClientDelegate.UnsentRequest} list and the poll time for the network poll *
  2. *