Index: core/src/main/scala/kafka/server/KafkaServer.scala
===================================================================
--- core/src/main/scala/kafka/server/KafkaServer.scala	(revision 1403482)
+++ core/src/main/scala/kafka/server/KafkaServer.scala	(working copy)
@@ -24,7 +24,7 @@
 import java.util.concurrent._
 import atomic.AtomicBoolean
 import org.I0Itec.zkclient.ZkClient
-import kafka.controller.KafkaController
+import kafka.controller.{ControllerStat, KafkaController}
 
 /**
  * Represents the lifecycle of a single Kafka broker. Handles all functionality required
@@ -99,9 +99,16 @@
     replicaManager.startup()
     // start the controller
     kafkaController.startup()
+    // register metrics beans
+    registerStats()
     info("started")
   }
 
+  def registerStats() {
+    BrokerTopicStat.getBrokerAllTopicStat()
+    ControllerStat.offlinePartitionRate
+    ControllerStat.uncleanLeaderElectionRate
+  }
 
   /**
    * Shutdown API for shutting down a single instance of the Kafka server.