Merge branch 'serejja-metric-reporters-fix'

mesos · Jul 29, 2015 · 4ac4f67 · 4ac4f67
2 parents baec260 + 273a010
commit 4ac4f67
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/scala/ly/stealth/mesos/kafka/BrokerServer.scala b/src/scala/ly/stealth/mesos/kafka/BrokerServer.scala
@@ -80,6 +80,11 @@ object BrokerServer {
       val config: Object = configClass.getConstructor(classOf[Properties]).newInstance(props).asInstanceOf[Object]
       val server: Object = serverClass.getConstructor(configClass).newInstance(config).asInstanceOf[Object]
 
+      val metricsReporter = loader.loadClass("kafka.metrics.KafkaMetricsReporter$").getField("MODULE$").get(null)
+      val metricsReporterClass = metricsReporter.getClass
+      val verifiableProps = config.getClass.getMethod("props").invoke(config)
+      metricsReporterClass.getMethod("startReporters", verifiableProps.getClass).invoke(metricsReporter, verifiableProps)
+
       server
     }