类 KafkaSpecialProducerConsumerConfigExample.MyConsumerMetricsReporter
- java.lang.Object
- org.springframework.boot.kafka.KafkaSpecialProducerConsumerConfigExample.MyConsumerMetricsReporter
- 所有已实现的接口:
org.apache.kafka.common.Configurable
,org.apache.kafka.common.metrics.MetricsReporter
public static class KafkaSpecialProducerConsumerConfigExample.MyConsumerMetricsReporter extends Object implements org.apache.kafka.common.metrics.MetricsReporter
构造器概要
构造器 构造器 说明 MyConsumerMetricsReporter()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 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)
构造器详细资料
MyConsumerMetricsReporter
public MyConsumerMetricsReporter()
方法详细资料
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