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

Class KafkaTelemetryFactory

java.lang.Object

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

@Factory
public final class KafkaTelemetryFactory
extends Object

Opentelemetery Kafka tracing factory.

Since:

4.5.0

Constructor Summary

Constructors

Constructor	Description
KafkaTelemetryFactory()

Method Summary

Modifier and Type	Method	Description
KafkaTelemetry	kafkaTelemetry(io.opentelemetry.api.OpenTelemetry openTelemetry, KafkaTelemetryConfiguration kafkaTelemetryConfiguration, io.micronaut.context.ApplicationContext applicationContext)
KafkaTelemetryHelper	kafkaTelemetryHelper(KafkaTelemetry kafkaTelemetry)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaTelemetryFactory

public KafkaTelemetryFactory()

Method Details

kafkaTelemetryHelper

@Singleton
public KafkaTelemetryHelper kafkaTelemetryHelper(KafkaTelemetry kafkaTelemetry)

kafkaTelemetry

@Singleton
public KafkaTelemetry kafkaTelemetry(io.opentelemetry.api.OpenTelemetry openTelemetry,
 KafkaTelemetryConfiguration kafkaTelemetryConfiguration,
 io.micronaut.context.ApplicationContext applicationContext)