org.apache.kafka.common.metrics

Class JmxReporter

java.lang.Object

org.apache.kafka.common.metrics.JmxReporter

All Implemented Interfaces:

java.lang.AutoCloseable, Configurable, MetricsReporter, Reconfigurable

public class JmxReporter
extends java.lang.Object
implements MetricsReporter

Register metrics in JMX as dynamic mbeans based on the metric names

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_EXCLUDE
static java.lang.String	DEFAULT_INCLUDE
static java.lang.String	EXCLUDE_CONFIG
static java.lang.String	EXCLUDE_CONFIG_ALIAS
static java.lang.String	INCLUDE_CONFIG
static java.lang.String	INCLUDE_CONFIG_ALIAS
static java.lang.String	JMX_IGNORE_TAG
static java.lang.String	METRICS_CONFIG_PREFIX
static java.util.Set<java.lang.String>	RECONFIGURABLE_CONFIGS

Constructor Summary

Constructors

Constructor and Description
JmxReporter()
JmxReporter(java.lang.String prefix) Deprecated. Since 2.6.0. Use JmxReporter() Initialize JmxReporter with contextChange(MetricsContext) Populate prefix by adding _namespace/prefix key value pair to MetricsContext

Method Summary

Modifier and Type	Method and Description
void	close() Called when the metrics repository is closed.
static java.util.function.Predicate<java.lang.String>	compilePredicate(java.util.Map<java.lang.String,?> originalConfig)
void	configure(java.util.Map<java.lang.String,?> configs) Configure this class with the given key-value pairs
boolean	containsMbean(java.lang.String mbeanName)
void	contextChange(MetricsContext metricsContext) Sets the context labels for the service or library exposing metrics.
void	init(java.util.List<KafkaMetric> metrics) This is called when the reporter is first registered to initially register all existing metrics
void	metricChange(KafkaMetric metric) This is called whenever a metric is updated or added
void	metricRemoval(KafkaMetric metric) This is called whenever a metric is removed
java.util.Set<java.lang.String>	reconfigurableConfigs() Returns the names of configs that may be reconfigured.
void	reconfigure(java.util.Map<java.lang.String,?> configs) Reconfigures this instance with the given key-value pairs.
void	validateReconfiguration(java.util.Map<java.lang.String,?> configs) Validates the provided configuration.

Methods inherited from class java.lang.Object

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

Field Detail

METRICS_CONFIG_PREFIX

public static final java.lang.String METRICS_CONFIG_PREFIX

See Also:

Constant Field Values

EXCLUDE_CONFIG

public static final java.lang.String EXCLUDE_CONFIG

See Also:

Constant Field Values

EXCLUDE_CONFIG_ALIAS

public static final java.lang.String EXCLUDE_CONFIG_ALIAS

See Also:

Constant Field Values

INCLUDE_CONFIG

public static final java.lang.String INCLUDE_CONFIG

See Also:

Constant Field Values

INCLUDE_CONFIG_ALIAS

public static final java.lang.String INCLUDE_CONFIG_ALIAS

See Also:

Constant Field Values

RECONFIGURABLE_CONFIGS

public static final java.util.Set<java.lang.String> RECONFIGURABLE_CONFIGS

DEFAULT_INCLUDE

public static final java.lang.String DEFAULT_INCLUDE

See Also:

Constant Field Values

DEFAULT_EXCLUDE

public static final java.lang.String DEFAULT_EXCLUDE

See Also:

Constant Field Values

JMX_IGNORE_TAG

public static final java.lang.String JMX_IGNORE_TAG

See Also:

Constant Field Values

Constructor Detail

JmxReporter

public JmxReporter()

JmxReporter

@Deprecated
public JmxReporter(java.lang.String prefix)

Deprecated. Since 2.6.0. Use JmxReporter() Initialize JmxReporter with contextChange(MetricsContext) Populate prefix by adding _namespace/prefix key value pair to MetricsContext

Create a JMX reporter that prefixes all metrics with the given string.

Method Detail

configure

public void configure(java.util.Map<java.lang.String,?> configs)

Description copied from interface: Configurable

Configure this class with the given key-value pairs

Specified by:

configure in interface Configurable

reconfigurableConfigs

public java.util.Set<java.lang.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(java.util.Map<java.lang.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(java.util.Map<java.lang.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(java.util.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(java.lang.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

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

close

public void close()

Description copied from interface: MetricsReporter

Called when the metrics repository is closed.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface MetricsReporter

compilePredicate

public static java.util.function.Predicate<java.lang.String> compilePredicate(java.util.Map<java.lang.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