Class JmxReporter

Method Details

• configure

  public void configure(Map<String,?> configs)

  Description copied from interface: Configurable

  Configure this class with the given key-value pairs

  Specified by:

  configure in interface Configurable

• reconfigurableConfigs

  public Set<String> reconfigurableConfigs()

  Description copied from interface: Reconfigurable

  Returns the names of configs that may be reconfigured.

  Specified by:

  reconfigurableConfigs in interface MetricsReporter

  Specified by:

  reconfigurableConfigs in interface Reconfigurable

• validateReconfiguration

  public void validateReconfiguration(Map<String,?> configs) throws ConfigException

  Description copied from interface: Reconfigurable

  Validates the provided configuration. The provided map contains all configs including any reconfigurable configs that may be different from the initial configuration. Reconfiguration will be not performed if this method throws any exception.

  Specified by:

  validateReconfiguration in interface MetricsReporter

  Specified by:

  validateReconfiguration in interface Reconfigurable

  Throws:

  ConfigException - if the provided configs are not valid. The exception message from ConfigException will be returned to the client in the AlterConfigs response.

• reconfigure

  public void reconfigure(Map<String,?> configs)

  Description copied from interface: Reconfigurable

  Reconfigures this instance with the given key-value pairs. The provided map contains all configs including any reconfigurable configs that may have changed since the object was initially configured using Configurable.configure(Map). This method will only be invoked if the configs have passed validation using Reconfigurable.validateReconfiguration(Map).

  Specified by:

  reconfigure in interface MetricsReporter

  Specified by:

  reconfigure in interface Reconfigurable

• init

  public void init(List<KafkaMetric> metrics)

  Description copied from interface: MetricsReporter

  This is called when the reporter is first registered to initially register all existing metrics

  Specified by:

  init in interface MetricsReporter

  Parameters:

  metrics - All currently existing metrics

• containsMbean

  public boolean containsMbean(String mbeanName)

• metricChange

  public void metricChange(KafkaMetric metric)

  Description copied from interface: MetricsReporter

  This is called whenever a metric is updated or added

  Specified by:

  metricChange in interface MetricsReporter

  Parameters:

  metric - The metric that has been added or changed

• metricRemoval

  public void metricRemoval(KafkaMetric metric)

  Description copied from interface: MetricsReporter

  This is called whenever a metric is removed

  Specified by:

  metricRemoval in interface MetricsReporter

  Parameters:

  metric - The metric that has been removed

• close

  public void close()

  Description copied from interface: MetricsReporter

  Called when the metrics repository is closed.

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in interface MetricsReporter

• compilePredicate

  public static Predicate<String> compilePredicate(Map<String,?> originalConfig)

• contextChange

  public void contextChange(MetricsContext metricsContext)

  Description copied from interface: MetricsReporter

  Sets the context labels for the service or library exposing metrics. This will be called before MetricsReporter.init(List) and may be called anytime after that.

  Specified by:

  contextChange in interface MetricsReporter

  Parameters:

  metricsContext - the metric context