diff --git a/app/org/apache/kafka/common/metrics/JmxReporter.scala b/app/org/apache/kafka/common/metrics/JmxReporter.scala new file mode 100644 index 000000000..13fdb6f1f --- /dev/null +++ b/app/org/apache/kafka/common/metrics/JmxReporter.scala @@ -0,0 +1,26 @@ +/** + * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 + * See accompanying LICENSE file. + */ + +package org.apache.kafka.common.metrics +import java.util + +import grizzled.slf4j.Logging + +/* +Override Kafka Client's implementation since we don't want to always report to Jmx + */ +class JmxReporter(prefix: String) extends MetricsReporter with Logging { + override def init(metrics: util.List[KafkaMetric]): Unit = {} + + override def metricChange(metric: KafkaMetric): Unit = {} + + override def metricRemoval(metric: KafkaMetric): Unit = {} + + override def close(): Unit = {} + + override def configure(configs: util.Map[String, _]): Unit = { + info("Using cmak JmxReporter") + } +}