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
