diff --git a/server-common/src/main/java/org/apache/kafka/admin/AdminUtils.java b/server-common/src/main/java/org/apache/kafka/admin/AdminUtils.java index 53fb9764e097..8c1d5a5cae1e 100644 --- a/server-common/src/main/java/org/apache/kafka/admin/AdminUtils.java +++ b/server-common/src/main/java/org/apache/kafka/admin/AdminUtils.java @@ -128,10 +128,10 @@ public static Map> assignReplicasToBrokers(Collection b.rack.isPresent())) return assignReplicasToBrokersRackUnaware(nPartitions, replicationFactor, brokerMetadatas.stream().map(b -> b.id).collect(Collectors.toList()), fixedStartIndex, - startPartitionId); + startPartitionId); else { return assignReplicasToBrokersRackAware(nPartitions, replicationFactor, brokerMetadatas, fixedStartIndex, - startPartitionId); + startPartitionId); } } @@ -194,7 +194,7 @@ private static Map> assignReplicasToBrokersRackAware(int // that do not have any replica, or // 2. the broker has already assigned a replica AND there is one or more brokers that do not have replica assigned if ((!racksWithReplicas.contains(rack) || racksWithReplicas.size() == numRacks) - && (!brokersWithReplicas.contains(broker) || brokersWithReplicas.size() == numBrokers)) { + && (!brokersWithReplicas.contains(broker) || brokersWithReplicas.size() == numBrokers)) { replicaBuffer.add(broker); racksWithReplicas.add(rack); brokersWithReplicas.add(broker);