diff --git a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java index 8beca098b9a..f5f6e2d3200 100644 --- a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java +++ b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java @@ -2288,7 +2288,7 @@ public class ReplicationControlManager { Arrays.stream(newPartInfo.elr).forEach(validationSet::add); if (validationSet.size() != newPartInfo.isr.length + newPartInfo.elr.length) { log.error("{}-{} has overlapping ISR={} and ELR={}", topics.get(topicId).name, partitionId, - Arrays.toString(newPartInfo.isr), partitionId, Arrays.toString(newPartInfo.elr)); + Arrays.toString(newPartInfo.isr), Arrays.toString(newPartInfo.elr)); } brokersToIsrs.update(topicId, partitionId, prevPartInfo == null ? null : prevPartInfo.isr, newPartInfo.isr, prevPartInfo == null ? NO_LEADER : prevPartInfo.leader, newPartInfo.leader);