io.micronaut.configuration.kafka.metrics

Class ConsumerKafkaMetricsReporter

java.lang.Object

io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter

All Implemented Interfaces:

io.micrometer.core.instrument.binder.MeterBinder, java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.metrics.MetricsReporter

@Internal
public class ConsumerKafkaMetricsReporter
extends java.lang.Object

A MetricsReporter class for consumer metrics.

Constructor Summary

Constructors

Constructor and Description
ConsumerKafkaMetricsReporter()

Method Summary

Modifier and Type	Method and Description
void	bindTo(io.micrometer.core.instrument.MeterRegistry registry)
protected java.lang.Object	clone()
void	close() Method to close bean.
void	configure(java.util.Map<java.lang.String,?> configs)
protected java.util.Set<java.lang.String>	getIncludedTags() The tags to include in the gauge.
protected java.lang.String	getMetricPrefix() Abstract method to implement with the metric prefix for the reporter.
void	init(java.util.List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
void	metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
void	metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerKafkaMetricsReporter

public ConsumerKafkaMetricsReporter()

Method Detail

clone

protected java.lang.Object clone()
                          throws java.lang.CloneNotSupportedException

Overrides:

clone in class java.lang.Object

Throws:

java.lang.CloneNotSupportedException

getMetricPrefix

protected java.lang.String getMetricPrefix()

Abstract method to implement with the metric prefix for the reporter.

Returns:

prefix name

close

@PreDestroy
public void close()

Method to close bean. This must remain here for metrics to continue to function correctly for some reason?!.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.kafka.common.metrics.MetricsReporter

bindTo

public void bindTo(@NonNull
                   io.micrometer.core.instrument.MeterRegistry registry)

Specified by:

bindTo in interface io.micrometer.core.instrument.binder.MeterBinder

init

public void init(java.util.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

configure

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

Specified by:

configure in interface org.apache.kafka.common.Configurable

getIncludedTags

protected java.util.Set<java.lang.String> getIncludedTags()

The tags to include in the gauge. Defaults to just the client-id.

Returns:

The tags to include