io.micronaut.configuration.kafka.metrics

Class KafkaConsumerMetrics

java.lang.Object

io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics

All Implemented Interfaces:

io.micrometer.core.instrument.binder.MeterBinder, BeanCreatedEventListener<AbstractKafkaConsumerConfiguration>, Closeable, AutoCloseable, EventListener

@RequiresMetrics
 @Context
 @Requires(property="micronaut.metrics.binders.kafka.enabled",
          value="true",
          defaultValue="true")
public class KafkaConsumerMetrics
extends Object
implements BeanCreatedEventListener<AbstractKafkaConsumerConfiguration>, io.micrometer.core.instrument.binder.MeterBinder, Closeable

Binds Kafka Metrics to Micrometer.

Since:

1.0

Author:

graemerocher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaConsumerMetrics.Reporter A MetricsReporter that binds metrics to micrometer.

Constructor Summary

Constructors

Constructor and Description
KafkaConsumerMetrics()

Method Summary

Modifier and Type	Method and Description
void	bindTo(io.micrometer.core.instrument.MeterRegistry registry)
void	close()
AbstractKafkaConsumerConfiguration	onCreated(BeanCreatedEvent<AbstractKafkaConsumerConfiguration> event) Fired when a bean is created and all PostConstruct initialization hooks have been called.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConsumerMetrics

public KafkaConsumerMetrics()

Method Detail

onCreated

public AbstractKafkaConsumerConfiguration onCreated(BeanCreatedEvent<AbstractKafkaConsumerConfiguration> event)

Description copied from interface: BeanCreatedEventListener

Fired when a bean is created and all PostConstruct initialization hooks have been called.

Specified by:

onCreated in interface BeanCreatedEventListener<AbstractKafkaConsumerConfiguration>

Parameters:

event - The bean created event

Returns:

The bean or a replacement bean of the same type

bindTo

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

Specified by:

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

close

@PreDestroy
public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable