dajac opened a new pull request, #13505: URL: https://github.com/apache/kafka/pull/13505
This patch adds the `ConcurrentEventQueue` which will be used in the runtime of the new group coordinator. The aim of this queue is to basically have a queue per __consumer_group partitions and to ensure that events addressed to the same partitions are not processed concurrently. The queue is generic so we could reuse it in different context. I am not really happy with the name but I could not come up with something better. I am open to suggestions. This patch is part of a series which will bring the new group coordinator runtime. I will open them more or less class by class in order to facilitate the reviews. ### 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
