类 KafkaSpecialProducerConsumerConfigExample.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