io.micronaut.tracing.opentelemetry.instrument.kafka

Class KafkaTelemetryFactory

java.lang.Object

io.micronaut.tracing.opentelemetry.instrument.kafka.KafkaTelemetryFactory

@Factory
public class KafkaTelemetryFactory
extends java.lang.Object

Opentelemetery Kafka tracing factory.

Since:

5.0.0

Constructor Summary

Constructors

Constructor and Description
KafkaTelemetryFactory()

Method Summary

Modifier and Type	Method and Description
io.opentelemetry.instrumentation.kafkaclients.KafkaTelemetry	kafkaTelemetry(io.opentelemetry.api.OpenTelemetry openTelemetry, KafkaTelemetryConfiguration kafkaTelemetryConfiguration) Create the KafkaTelemetry bean.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTelemetryFactory

public KafkaTelemetryFactory()

Method Detail

kafkaTelemetry

@Singleton
public io.opentelemetry.instrumentation.kafkaclients.KafkaTelemetry kafkaTelemetry(io.opentelemetry.api.OpenTelemetry openTelemetry,
                                                                                              KafkaTelemetryConfiguration kafkaTelemetryConfiguration)

Create the KafkaTelemetry bean.

Parameters:

openTelemetry - opentelemetry bean

kafkaTelemetryConfiguration - kafkaTelemetryConfiguration bean

Returns:

The KafkaTelemetry bean