rajinisivaram commented on code in PR #13350: URL: https://github.com/apache/kafka/pull/13350#discussion_r1149064166
########## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java: ########## @@ -574,6 +697,42 @@ private void assignOwnedPartitions() { } } + // Round-Robin filling within racks for remaining members up to the expected numbers of maxQuota, + // otherwise, to minQuota + private void assignRackAwareRoundRobin(List<TopicPartition> unassignedPartitions) { + int nextUnfilledConsumerIndex = 0; + Iterator<TopicPartition> unassignedIter = unassignedPartitions.iterator(); + while (!rackInfo.consumerRacks.isEmpty() && unassignedIter.hasNext()) { Review Comment: We don't mutate consumerRacks, updated to return early if empty. -- 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