From 1e83f7ebdb693598aa1bb0b5ceb335dea66f53d9 Mon Sep 17 00:00:00 2001 From: Sriram Subramanian Date: Wed, 5 Jun 2013 21:48:53 -0700 Subject: [PATCH] shutdown tool change --- core/src/main/scala/kafka/admin/ShutdownBroker.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/main/scala/kafka/admin/ShutdownBroker.scala b/core/src/main/scala/kafka/admin/ShutdownBroker.scala index bb20edb..2dd47e7 100644 --- a/core/src/main/scala/kafka/admin/ShutdownBroker.scala +++ b/core/src/main/scala/kafka/admin/ShutdownBroker.scala @@ -25,7 +25,7 @@ import javax.management.remote.{JMXServiceURL, JMXConnectorFactory} import javax.management.ObjectName import kafka.controller.KafkaController import scala.Some -import kafka.common.BrokerNotAvailableException +import kafka.common.{TopicAndPartition, BrokerNotAvailableException} object ShutdownBroker extends Logging { @@ -58,8 +58,8 @@ object ShutdownBroker extends Logging { val leaderPartitionsRemaining = mbsc.invoke(new ObjectName(KafkaController.MBeanName), "shutdownBroker", Array(params.brokerId), - Array(classOf[Int].getName)).asInstanceOf[Int] - val shutdownComplete = (leaderPartitionsRemaining == 0) + Array(classOf[Int].getName)).asInstanceOf[Set[TopicAndPartition]] + val shutdownComplete = (leaderPartitionsRemaining.size == 0) info("Shutdown status: " + (if (shutdownComplete) "complete" else "incomplete (broker still leads %d partitions)".format(leaderPartitionsRemaining))) shutdownComplete -- 1.7.12.4 (Apple Git-37)