DimitarMilushev opened a new pull request, #19186: URL: https://github.com/apache/kafka/pull/19186
### Tasks: - [x] Add a custom [SelectorProvider](clients/src/main/java/org/apache/kafka/common/network/SelectorProvider.java). - [x] Update [Selector](clients/src/main/java/org/apache/kafka/common/network/Selector.java) to utilize the custom SelectorProvider. ### Changes: The [SelectorProvider](clients/src/main/java/org/apache/kafka/common/network/SelectorProvider.java) fixes an issue where the static method `Selector.open()` would create a system-wide default SelectorProvider object whereas in our case we need a custom SelectorProvider. This implementation utilizes ThreadLocal so that each thread can reuse the configured provider within its' own context. The [Selector](clients/src/main/java/org/apache/kafka/common/network/Selector.java) code is updated to use our custom SelectorProvider from `org.apache.kafka.common.network`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
