public class KafkaServerMetricsReporter
extends java.lang.Object
implements org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.ClusterResourceListener
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
KAFKA |
static java.lang.String |
LABEL_BROKER_ID |
static java.lang.String |
LABEL_CLUSTER_ID |
Constructor and Description |
---|
KafkaServerMetricsReporter() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Called when the metrics repository is closed.
|
void |
configure(java.util.Map<java.lang.String,?> configs)
Configure this class with the given key-value pairs
|
java.util.List<MetricsCollector> |
getCollectors() |
void |
init(java.util.List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
This is called when the collectorTask 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 static final java.lang.String LABEL_CLUSTER_ID
public static final java.lang.String LABEL_BROKER_ID
public static final java.lang.String KAFKA
public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
onUpdate
in interface org.apache.kafka.common.ClusterResourceListener
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public java.util.List<MetricsCollector> getCollectors()
public void close()
close
in interface java.lang.AutoCloseable
close
in interface org.apache.kafka.common.metrics.MetricsReporter
public void init(java.util.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