io.confluent.metrics.reporter

Class ConfluentMetricsReporter

java.lang.Object

io.confluent.metrics.reporter.ConfluentMetricsReporter

All Implemented Interfaces:

AutoCloseable, org.apache.kafka.common.ClusterResourceListener, org.apache.kafka.common.Configurable, org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.Reconfigurable

public class ConfluentMetricsReporter
extends Object
implements org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.ClusterResourceListener

Constructor Summary

Constructors

Constructor and Description
ConfluentMetricsReporter()

Method Summary

Modifier and Type	Method and Description
void	close() Called when the metrics repository is closed.
void	configure(Map<String,?> configs) Configure this class with the given key-value pairs
void	contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
protected io.confluent.metrics.record.ConfluentMetric.MetricsMessage.Builder	getMetricsMessageBuilder(long timestamp)
void	init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics) This is called when the reporter is first registered to initially register all existing 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
protected Runnable	metricReportRunnable()
void	onUpdate(org.apache.kafka.common.ClusterResource clusterResource)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.metrics.MetricsReporter

reconfigurableConfigs, reconfigure, validateReconfiguration

Constructor Detail

ConfluentMetricsReporter

public ConfluentMetricsReporter()

Method Detail

contextChange

public void contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)

Specified by:

contextChange in interface org.apache.kafka.common.metrics.MetricsReporter

onUpdate

public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)

Specified by:

onUpdate in interface org.apache.kafka.common.ClusterResourceListener

configure

public void configure(Map<String,?> configs)

Configure this class with the given key-value pairs

Specified by:

configure in interface org.apache.kafka.common.Configurable

getMetricsMessageBuilder

protected io.confluent.metrics.record.ConfluentMetric.MetricsMessage.Builder getMetricsMessageBuilder(long timestamp)

close

public void close()

Called when the metrics repository is closed.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.kafka.common.metrics.MetricsReporter

init

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

This is called when the reporter is first registered to initially register all existing metrics

Specified by:

init in interface org.apache.kafka.common.metrics.MetricsReporter

Parameters:

metrics - All currently existing metrics

metricChange

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

This is called whenever a metric is updated or added

Specified by:

metricChange in interface org.apache.kafka.common.metrics.MetricsReporter

metricRemoval

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

This is called whenever a metric is removed

Specified by:

metricRemoval in interface org.apache.kafka.common.metrics.MetricsReporter

metricReportRunnable

protected Runnable metricReportRunnable()