public class KafkaMetricsCollector extends Object implements MetricsCollector, org.apache.kafka.common.metrics.MetricsReporter
Modifier and Type | Field and Description |
---|---|
static String |
KAFKA_METRICS_LIB |
LABEL_COLLECTOR, LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE
Constructor and Description |
---|
KafkaMetricsCollector() |
KafkaMetricsCollector(Clock clock,
Context context) |
KafkaMetricsCollector(Context context) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
collect(Emitter emitter) |
void |
configure(Map<String,?> configs) |
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
|
void |
setContext(Context context) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
start, stop
public static final String KAFKA_METRICS_LIB
public KafkaMetricsCollector()
public KafkaMetricsCollector(Context context)
public void setContext(Context context)
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
init
in interface org.apache.kafka.common.metrics.MetricsReporter
public 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
public void close()
close
in interface AutoCloseable
close
in interface org.apache.kafka.common.metrics.MetricsReporter
public void collect(Emitter emitter)
collect
in interface MetricsCollector