adixitconfluent opened a new pull request, #18864: URL: https://github.com/apache/kafka/pull/18864
### About The current `SimpleAssignor` in AK assigned all subscribed topic partitions to all the share group members. This does not match the description given in [KIP-932](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=255070434#KIP932:QueuesforKafka-TheSimpleAssignor). Here are the rules as mentioned in the KIP by which the assignment should happen - 1. The assignor hashes the member IDs of the members and maps the partitions assigned to the members based on the hash. This gives approximately even balance. 2. If any partitions were not assigned any members by (1) and do not have members already assigned in the current assignment, members are assigned round-robin until each partition has at least one member assigned to it. 3. If any partitions were assigned members by (1) and also have members in the current assignment assigned by (2), the members assigned by (2) are removed. ### Tests The added code has been verified with unit tests and the already present integration tests. -- 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
