Package org.springframework.boot.kafka
Class KafkaSpecialProducerConsumerConfigExample.MyProducerMetricsReporter
- java.lang.Object
- org.springframework.boot.kafka.KafkaSpecialProducerConsumerConfigExample.MyProducerMetricsReporter
- All Implemented Interfaces:
org.apache.kafka.common.Configurable
,org.apache.kafka.common.metrics.MetricsReporter
- Enclosing class:
- KafkaSpecialProducerConsumerConfigExample
public static class KafkaSpecialProducerConsumerConfigExample.MyProducerMetricsReporter extends Object implements org.apache.kafka.common.metrics.MetricsReporter
Constructor Summary
Constructors Constructor Description MyProducerMetricsReporter()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
configure(Map<String,?> configs)
void
init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
void
metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
void
metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
Constructor Detail
MyProducerMetricsReporter
public MyProducerMetricsReporter()
Method Detail
configure
public void configure(Map<String,?> configs)
- Specified by:
configure
in interfaceorg.apache.kafka.common.Configurable
init
public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
- Specified by:
init
in interfaceorg.apache.kafka.common.metrics.MetricsReporter
metricChange
public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
- Specified by:
metricChange
in interfaceorg.apache.kafka.common.metrics.MetricsReporter
metricRemoval
public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
- Specified by:
metricRemoval
in interfaceorg.apache.kafka.common.metrics.MetricsReporter
close
public void close()
- Specified by:
close
in interfaceorg.apache.kafka.common.metrics.MetricsReporter