public class KafkaMetricsCollector extends Object implements MetricsCollector
LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE
Constructor and Description |
---|
KafkaMetricsCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy) |
Modifier and Type | Method and Description |
---|---|
void |
collect(Emitter emitter) |
void |
init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics) |
void |
metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
This is called whenever a metric is updated or added
|
void |
metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
This is called whenever a metric is removed
|
String |
toString() |
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
start, stop
public KafkaMetricsCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy)
public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
public void collect(Emitter emitter)
collect
in interface MetricsCollector