rreddy-22 opened a new pull request, #15974: URL: https://github.com/apache/kafka/pull/15974
During performance testing we observed that calculating the unassigned partitions by first initializing the set with all of the topic partitions within the Uniform assignor is a costly process, this can be improved by using a reverse lookup map between topicIdPartition and the member. This patch adds the following: 1. A new map to the consumer group state called **partitionAssignments** which is a reverse lookup map from each partition to the member it is assigned to. This map is updated every time the target assignment is updated. 2. A new interface called GroupSpec which is implemented by the existing assignmentSpec. 3. The GroupSpec interface contains a new method called isPartitionAssigned. The most performance improvements should be noticeable in the Uniform Optimized Assignment Builder. -- 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
