Package 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	Description
KafkaMetricsCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy)

Method Summary

Modifier and Type	Method	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

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

start, stop

Constructor Details

KafkaMetricsCollector

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

Method Details

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