From 058cd5a24e5d942f67d363367f43378148d045ea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AE=B8=E6=99=93=E4=B8=9C?= <763795151@qq.com> Date: Thu, 20 Jan 2022 13:44:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E5=BD=93=E5=89=8D=E9=87=8D?= =?UTF-8?q?=E5=88=86=E9=85=8D=EF=BC=8C=E7=89=88=E6=9C=AC=E4=B8=8D=E6=94=AF?= =?UTF-8?q?=E6=8C=81=E5=BC=82=E5=B8=B8=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 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 53510dc..1438f38 100644 --- a/src/main/scala/kafka/console/OperationConsole.scala +++ b/src/main/scala/kafka/console/OperationConsole.scala @@ -242,8 +242,8 @@ class OperationConsole(config: KafkaConfig, topicConsole: TopicConsole, withAdminClientAndCatchError(admin => { admin.listPartitionReassignments(withTimeoutMs(new ListPartitionReassignmentsOptions)).reassignments().get() }, e => { - Collections.emptyMap() log.error("listPartitionReassignments error.", e) + Collections.emptyMap() }).asInstanceOf[util.Map[TopicPartition, PartitionReassignment]] }