kirktrue opened a new pull request, #19865: URL: https://github.com/apache/kafka/pull/19865
Three changes to the `AsyncKafkaConsumer`’s internals to reduce the CPU usage: 1. Switching from using `Selector.wakeup()` to `Queue.poll()` as the mechanism to alert the network thread that there's work to do 2. Unrolling the Java Streams API usage into old-style `for` loops to remove overhead in critical path 3. Removing the random ID generation for each application and background event -- 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
