From 984e39c6cfdd237aa86ade45e5079620429352b7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AE=B8=E6=99=93=E4=B8=9C?= <763795151@qq.com> Date: Wed, 10 Nov 2021 21:00:34 +0800 Subject: [PATCH] preferred as leader. --- src/main/scala/kafka/console/OperationConsole.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/kafka/console/OperationConsole.scala b/src/main/scala/kafka/console/OperationConsole.scala index 33c9a07..53d0858 100644 --- a/src/main/scala/kafka/console/OperationConsole.scala +++ b/src/main/scala/kafka/console/OperationConsole.scala @@ -201,7 +201,7 @@ class OperationConsole(config: KafkaConfig, topicConsole: TopicConsole, admin.electLeaders(ElectionType.PREFERRED, partitions, withTimeoutMs(new ElectLeadersOptions)).all().get() (true, "") }, e => { - log.error("alter config error.", e) + log.error("electLeaders error.", e) (false, e.getMessage) }).asInstanceOf[(Boolean, String)] }