Class KafkaConsumerMetrics
java.lang.Object
io.micronaut.configuration.kafka.metrics.AbstractKafkaMetrics<AbstractKafkaConsumerConfiguration>
io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics
- All Implemented Interfaces:
io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConsumerConfiguration>
,EventListener
@RequiresMetrics
@Context
@Requires(property="micronaut.metrics.binders.kafka.enabled",
value="true",
defaultValue="true")
public class KafkaConsumerMetrics
extends AbstractKafkaMetrics<AbstractKafkaConsumerConfiguration>
implements io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConsumerConfiguration>
Binds Kafka Metrics to Micrometer.
- Since:
- 1.0
- Author:
- graemerocher
-
Constructor Summary
ConstructorDescriptionKafkaConsumerMetrics
(io.micronaut.context.BeanLocator beanLocator) Default constructor. -
Method Summary
Modifier and TypeMethodDescriptiononCreated
(io.micronaut.context.event.BeanCreatedEvent<AbstractKafkaConsumerConfiguration> event) Methods inherited from class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetrics
addKafkaMetrics, addKafkaMetrics
-
Constructor Details
-
KafkaConsumerMetrics
public KafkaConsumerMetrics(io.micronaut.context.BeanLocator beanLocator) Default constructor.- Parameters:
beanLocator
- The bean locator
-
-
Method Details
-
onCreated
public AbstractKafkaConsumerConfiguration onCreated(io.micronaut.context.event.BeanCreatedEvent<AbstractKafkaConsumerConfiguration> event) - Specified by:
onCreated
in interfaceio.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConsumerConfiguration>
-