类 KafkaSpecialProducerConsumerConfigExample.MyProducerMetricsReporter
- java.lang.Object
 - org.springframework.boot.kafka.KafkaSpecialProducerConsumerConfigExample.MyProducerMetricsReporter
 
- 所有已实现的接口:
 org.apache.kafka.common.Configurable,org.apache.kafka.common.metrics.MetricsReporter
public static class KafkaSpecialProducerConsumerConfigExample.MyProducerMetricsReporter extends Object implements org.apache.kafka.common.metrics.MetricsReporter
构造器概要
构造器 构造器 说明 MyProducerMetricsReporter()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 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)
构造器详细资料
MyProducerMetricsReporter
public MyProducerMetricsReporter()
方法详细资料
configure
public void configure(Map<String,?> configs)
- 指定者:
 configure在接口中org.apache.kafka.common.Configurable
init
public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
- 指定者:
 init在接口中org.apache.kafka.common.metrics.MetricsReporter
metricChange
public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
- 指定者:
 metricChange在接口中org.apache.kafka.common.metrics.MetricsReporter
metricRemoval
public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
- 指定者:
 metricRemoval在接口中org.apache.kafka.common.metrics.MetricsReporter
close
public void close()
- 指定者:
 close在接口中org.apache.kafka.common.metrics.MetricsReporter