io.micronaut.configuration.kafka.streams.metrics

Class KafkaStreamsMetricsReporter

java.lang.Object

io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter

io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetricsReporter

All Implemented Interfaces:

io.micrometer.core.instrument.binder.MeterBinder, java.io.Closeable, java.lang.AutoCloseable, Configurable, MetricsReporter, Reconfigurable

public class KafkaStreamsMetricsReporter
extends AbstractKafkaMetricsReporter

Kafka streams specific metrics reporter which prefixes all metrics with kafka-streams.

Field Summary

Fields inherited from class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter

CLIENT_ID_TAG, NODE_ID_TAG, TOPIC_TAG

Constructor Summary

Constructors

Constructor and Description
KafkaStreamsMetricsReporter()

Method Summary

Modifier and Type	Method and Description
void	close() Method to close bean.
protected java.lang.String	getMetricPrefix() Abstract method to implement with the metric prefix for the reporter.

Methods inherited from class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter

bindTo, configure, getIncludedTags, init, metricChange, metricRemoval

Methods inherited from class java.lang.Object

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

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

contextChange, reconfigurableConfigs, reconfigure, validateReconfiguration

Constructor Detail

KafkaStreamsMetricsReporter

public KafkaStreamsMetricsReporter()

Method Detail

getMetricPrefix

protected java.lang.String getMetricPrefix()

Description copied from class: AbstractKafkaMetricsReporter

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

Specified by:

getMetricPrefix in class AbstractKafkaMetricsReporter

Returns:

prefix name

close

@PreDestroy
public void close()

Method to close bean.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface MetricsReporter

Overrides:

close in class AbstractKafkaMetricsReporter