You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/12/05 00:46:15 UTC
git commit: kafka-1168;
OfflinePartitionCount in JMX can be incorrect during controlled
shutdown; patched by Jun Rao; reviewed by Swapnil Ghike
Updated Branches:
refs/heads/trunk 6c36beef8 -> 8a2ba3f6f
kafka-1168; OfflinePartitionCount in JMX can be incorrect during controlled shutdown; patched by Jun Rao; reviewed by Swapnil Ghike
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8a2ba3f6
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8a2ba3f6
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8a2ba3f6
Branch: refs/heads/trunk
Commit: 8a2ba3f6f2eab88db4b5ea6d880ec2feba93276c
Parents: 6c36bee
Author: Jun Rao <ju...@gmail.com>
Authored: Wed Dec 4 15:47:18 2013 -0800
Committer: Jun Rao <ju...@gmail.com>
Committed: Wed Dec 4 15:47:18 2013 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/controller/KafkaController.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/8a2ba3f6/core/src/main/scala/kafka/controller/KafkaController.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala b/core/src/main/scala/kafka/controller/KafkaController.scala
index a1e0f29..3beaf75 100644
--- a/core/src/main/scala/kafka/controller/KafkaController.scala
+++ b/core/src/main/scala/kafka/controller/KafkaController.scala
@@ -134,7 +134,7 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient) extends Logg
if (!isActive())
0
else
- controllerContext.partitionLeadershipInfo.count(p => !controllerContext.liveBrokerIds.contains(p._2.leaderAndIsr.leader))
+ controllerContext.partitionLeadershipInfo.count(p => !controllerContext.liveOrShuttingDownBrokerIds.contains(p._2.leaderAndIsr.leader))
}
}
}