public class ConfluentMetricsReporter extends Object implements org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.ClusterResourceListener
Constructor and Description |
---|
ConfluentMetricsReporter() |
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) |
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
|
void |
onUpdate(org.apache.kafka.common.ClusterResource clusterResource) |
public void contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
contextChange
in interface org.apache.kafka.common.metrics.MetricsReporter
public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
onUpdate
in interface org.apache.kafka.common.ClusterResourceListener
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void close()
close
in interface AutoCloseable
close
in interface org.apache.kafka.common.metrics.MetricsReporter
public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
init
in interface org.apache.kafka.common.metrics.MetricsReporter
metrics
- All currently existing metricspublic void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
metricChange
in interface org.apache.kafka.common.metrics.MetricsReporter
public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
metricRemoval
in interface org.apache.kafka.common.metrics.MetricsReporter