root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix hint in selector poll (#13324) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
hudeqi 2023-03-05 21:12:52 +08:00 committed by GitHub
parent 8707e2cb6b
commit 1ae6405c47
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/common/network/Selector.java
View File

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