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 voidclose()voidconfigure(Map<String,?> configs)voidinit(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)voidmetricChange(org.apache.kafka.common.metrics.KafkaMetric metric)voidmetricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
Constructor Detail
MyProducerMetricsReporter
public MyProducerMetricsReporter()
Method Detail
configure
public void configure(Map<String,?> configs)
- Specified by:
configurein interfaceorg.apache.kafka.common.Configurable
init
public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
- Specified by:
initin interfaceorg.apache.kafka.common.metrics.MetricsReporter
metricChange
public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
- Specified by:
metricChangein interfaceorg.apache.kafka.common.metrics.MetricsReporter
metricRemoval
public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
- Specified by:
metricRemovalin interfaceorg.apache.kafka.common.metrics.MetricsReporter
close
public void close()
- Specified by:
closein interfaceorg.apache.kafka.common.metrics.MetricsReporter