Class ConfluentMetricsReporter

java.lang.Object
io.confluent.metrics.reporter.ConfluentMetricsReporter
All Implemented Interfaces:
AutoCloseable, org.apache.kafka.common.ClusterResourceListener, org.apache.kafka.common.Configurable, org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.Reconfigurable
public class ConfluentMetricsReporter extends Object implements org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.ClusterResourceListener

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConfluentMetricsReporter()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Called when the metrics repository is closed.
    void
    configure(Map<String,?> configs)
    Configure this class with the given key-value pairs
    void
    contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
     
    void
    init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
    This is called when the reporter is first registered to initially register all existing metrics
    void
    metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
    This is called whenever a metric is updated or added
    void
    metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
    This is called whenever a metric is removed
    void
    onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
     

    Methods inherited from class Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.kafka.common.metrics.MetricsReporter

    reconfigurableConfigs, reconfigure, validateReconfiguration

  • Constructor Details

    • ConfluentMetricsReporter

      public ConfluentMetricsReporter()

  • Method Details

    • contextChange

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

    • onUpdate

      public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
      Specified by:
      onUpdate in interface org.apache.kafka.common.ClusterResourceListener

    • configure

      public void configure(Map<String,?> configs)
      Configure this class with the given key-value pairs
      Specified by:
      configure in interface org.apache.kafka.common.Configurable

    • close

      public void close()
      Called when the metrics repository is closed.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface org.apache.kafka.common.metrics.MetricsReporter

    • init

      public void init(List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
      This is called when the reporter is first registered to initially register all existing metrics
      Specified by:
      init in interface org.apache.kafka.common.metrics.MetricsReporter
      Parameters:
      metrics - All currently existing metrics

    • metricChange

      public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
      This is called whenever a metric is updated or added
      Specified by:
      metricChange in interface org.apache.kafka.common.metrics.MetricsReporter

    • metricRemoval

      public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
      This is called whenever a metric is removed
      Specified by:
      metricRemoval in interface org.apache.kafka.common.metrics.MetricsReporter