io.micronaut.configuration.kafka.metrics

Class AbstractKafkaMetrics<T extends AbstractKafkaConfiguration>

java.lang.Object

io.micronaut.configuration.kafka.metrics.AbstractKafkaMetrics<T>

Type Parameters:

T - An abstract kafka configuration

Direct Known Subclasses:

KafkaConsumerMetrics, KafkaProducerMetrics, KafkaStreamsMetrics

@Internal
public abstract class AbstractKafkaMetrics<T extends AbstractKafkaConfiguration>
extends java.lang.Object

A class to simplify the producer and consumer metric.reporters default property.

Since:

1.0

Author:

Christian Oestreich

Constructor Summary

Constructors

Constructor and Description
AbstractKafkaMetrics()

Method Summary

Modifier and Type	Method and Description
protected T	addKafkaMetrics(io.micronaut.context.event.BeanCreatedEvent<T> event, java.lang.String kafkaMetricsReporterClassName) Method to add a default metric reporter if not otherwise defined.
protected T	addKafkaMetrics(io.micronaut.context.event.BeanCreatedEvent<T> event, java.lang.String kafkaMetricsReporterClassName, io.micrometer.core.instrument.MeterRegistry meterRegistry) Method to add a default metric reporter if not otherwise defined.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractKafkaMetrics

public AbstractKafkaMetrics()

Method Detail

addKafkaMetrics

protected T addKafkaMetrics(io.micronaut.context.event.BeanCreatedEvent<T> event,
                            java.lang.String kafkaMetricsReporterClassName)

Method to add a default metric reporter if not otherwise defined.

Parameters:

event - The event for bean created of type AbstractKafkaConfiguration

kafkaMetricsReporterClassName - The class name to use for kafka metrics registration

Returns:

The bean

addKafkaMetrics

protected T addKafkaMetrics(io.micronaut.context.event.BeanCreatedEvent<T> event,
                            java.lang.String kafkaMetricsReporterClassName,
                            @Nullable
                            io.micrometer.core.instrument.MeterRegistry meterRegistry)

Method to add a default metric reporter if not otherwise defined.

Parameters:

event - The event for bean created of type AbstractKafkaConfiguration

kafkaMetricsReporterClassName - The class name to use for kafka metrics registration

meterRegistry - The meter registry instance to send metrics to

Returns:

The bean