Fix for Kafka metrics reporters

mesos · Jul 29, 2015 · 273a010 · 273a010
1 parent baec260
commit 273a010
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
     }