Class KafkaSpecialProducerConsumerConfigExample.MyConsumerMetricsReporter

    • Method Detail

      • configure

        public void configure​(Map<String,​?> configs)
        Specified by:
        configure in interface org.apache.kafka.common.Configurable
      • init

        public void init​(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
        Specified by:
        init in interface org.apache.kafka.common.metrics.MetricsReporter
      • metricChange

        public void metricChange​(org.apache.kafka.common.metrics.KafkaMetric metric)
        Specified by:
        metricChange in interface org.apache.kafka.common.metrics.MetricsReporter
      • metricRemoval

        public void metricRemoval​(org.apache.kafka.common.metrics.KafkaMetric metric)
        Specified by:
        metricRemoval in interface org.apache.kafka.common.metrics.MetricsReporter
      • close

        public void close()
        Specified by:
        close in interface org.apache.kafka.common.metrics.MetricsReporter