From 1ae6405c479636bc0a4e0ffda91c82ea3bd3a761 Mon Sep 17 00:00:00 2001 From: hudeqi <1217150961@qq.com> Date: Sun, 5 Mar 2023 21:12:52 +0800 Subject: [PATCH] MINOR: Fix hint in selector poll (#13324) Reviewers: Chia-Ping Tsai --- .../src/main/java/org/apache/kafka/common/network/Selector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/common/network/Selector.java b/clients/src/main/java/org/apache/kafka/common/network/Selector.java index 67e27e9a293..0a047d5a57e 100644 --- a/clients/src/main/java/org/apache/kafka/common/network/Selector.java +++ b/clients/src/main/java/org/apache/kafka/common/network/Selector.java @@ -479,7 +479,7 @@ public class Selector implements Selectable, AutoCloseable { // Poll from channels where the underlying socket has more data pollSelectionKeys(readyKeys, false, endSelect); - // Clear all selected keys so that they are included in the ready count for the next select + // Clear all selected keys so that they are excluded from the ready count for the next select readyKeys.clear(); pollSelectionKeys(immediatelyConnectedKeys, true, endSelect);