jolshan commented on code in PR #16088:
URL: https://github.com/apache/kafka/pull/16088#discussion_r1621424229
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##########
@@ -71,63 +69,54 @@ public class OptimizedUniformAssignmentBuilder extends
AbstractUniformAssignment
*/
private final Set<Uuid> subscribedTopicIds;
- /**
- * The number of members to receive an extra partition beyond the minimum
quota.
- * Minimum Quota = Total Partitions / Total Members
- * Example: If there are 11 partitions to be distributed among 3 members,
- * each member gets 3 (11 / 3) [minQuota] partitions and 2 (11 %
3) members get an extra partition.
- */
- private int remainingMembersToGetAnExtraPartition;
-
/**
* Members mapped to the remaining number of partitions needed to meet the
minimum quota.
- * Minimum quota = total partitions / total members.
*/
- private Map<String, Integer> potentiallyUnfilledMembers;
+ private final List<MemberWithRemainingQuota> potentiallyUnfilledMembers;
Review Comment:
why do we call this potentiallyUnfilledMembers rather than unfilledMembers?
--
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
