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);