Package io.micronaut.tracing.opentelemetry.instrument.kafka

@Configuration @Requires(property="otel.instrumentation.kafka.enabled",notEquals="false") @Requires(classes=org.apache.kafka.clients.consumer.Consumer.class) package io.micronaut.tracing.opentelemetry.instrument.kafka

Contains configuration that provide integration with Kafka Opentelemetry.

Since:

4.5.0

Class	Description
KafkaAttributesExtractorUtils	Utility class to help get kafka headers and put them as span attributes.
KafkaTelemetry	The main class with opentelemetry-kafka logic.
KafkaTelemetryBuilder	Builder class for KafkaTelemetry object.
KafkaTelemetryConfiguration	Configuration properties for KafkaTelemetry.
KafkaTelemetryConsumerTracingFilter<K,V>	Interface to filter consumer messages for tracing.
KafkaTelemetryConsumerTracingInstrumentation	Kafka consumer tracing instrumentation using OpenTelemetry.
KafkaTelemetryFactory	Opentelemetery Kafka tracing factory.
KafkaTelemetryHelper	Helper-class to access to kafkaTelemetry object from non-micronaut components.
KafkaTelemetryProducerTracingFilter<K,V>	Interface to filter producer messages for tracing.
KafkaTelemetryProducerTracingInstrumentation	Kafka consumer tracing instrumentation using OpenTelemetry.
TracingConsumerInterceptor<K,V>	Default tracing consumer kafka interceptor.
TracingProducerInterceptor<K,V>	Default tracing producer kafka interceptor.