io.confluent.telemetry.collector

Class KafkaMetricsCollector

java.lang.Object

io.confluent.telemetry.collector.KafkaMetricsCollector

All Implemented Interfaces:

MetricsCollector

public class KafkaMetricsCollector
extends Object
implements MetricsCollector

Field Summary

Fields inherited from interface io.confluent.telemetry.collector.MetricsCollector

LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE

Constructor Summary

Constructors

Constructor and Description
KafkaMetricsCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.confluent.telemetry.collector.MetricsCollector

start, stop

Constructor Detail

KafkaMetricsCollector

public KafkaMetricsCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy)

Method Detail

init

public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)

metricChange

public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)

This is called whenever a metric is updated or added

metricRemoval

public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)

This is called whenever a metric is removed

collect

public void collect(Emitter emitter)

Specified by:

collect in interface MetricsCollector

toString

public String toString()

Overrides:

toString in class Object