mimaison opened a new pull request #11560: URL: https://github.com/apache/kafka/pull/11560
Implements KIP-788. The number of network threads can be set per listener using the following syntax: listener.name.<listener>.num.network.threads=<num> It's currently a draft PR, there are still a bunch of TODOs and disabled tests. Before fixing them, I'd like to discuss a couple of things: - I renamed processor threads. They used to be numbered globally and now are numbered by listener. - I updated processor metrics to include the listener name otherwise metrics would collide. These are not described in the KIP but while implementing it, it made sense to handle all the processor creation/deletion in Acceptor. As there's an acceptor by listener, I made DataPlaneAcceptor a ListenerReconfigurable. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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
