This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 1ae6405c479 MINOR: Fix hint in selector poll (#13324)
1ae6405c479 is described below

commit 1ae6405c479636bc0a4e0ffda91c82ea3bd3a761
Author: hudeqi <[email protected]>
AuthorDate: Sun Mar 5 21:12:52 2023 +0800

    MINOR: Fix hint in selector poll (#13324)
    
    Reviewers: Chia-Ping Tsai <[email protected]>
---
 clients/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);

Reply via email to