diff --git a/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala b/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala index 03737aa532..92edcad003 100644 --- a/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala +++ b/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala @@ -166,7 +166,7 @@ object LeaderElectionCommand extends Logging { } if (noop.nonEmpty) { - val partitions = succeeded.mkString(", ") + val partitions = noop.mkString(", ") println(s"Valid replica already elected for partitions $partitions") }