rreddy-22 opened a new pull request, #13616: URL: https://github.com/apache/kafka/pull/13616
Part of KIP-848 https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol As a part of the new protocol, there will be assignors on the server side as well to take some load off the client. The group coordinator either directly computes the new target assignment for the group based on its default server-side assignor or requests a new assignment from one of the members in the group. There will be two types of assignors :- Range, Uniform. This PR is for the Server side range assignor. This PR is for the Optimized Uniform Assignor which has two parts to it: 1) When all the subscriptions are equal we do an optimized assignment 2) When the subscriptions are different we do a general assignment **The optimized uniform assignor has the liberty to treat each partition with equal weight since any member can get any partition from the subscribed topics. This makes it easier to distribute partitions and calculate quotas as a whole.** The tests aim to cover all the possible cases when a re-assignment can be triggered. -- 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
