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

Class KafkaTelemetryBuilder

java.lang.Object

io.micronaut.tracing.opentelemetry.instrument.kafka.KafkaTelemetryBuilder

@Internal
public final class KafkaTelemetryBuilder
extends Object

Builder class for KafkaTelemetry object.

Since:

5.0.0

Constructor Summary

Constructors

Constructor	Description
KafkaTelemetryBuilder(io.opentelemetry.api.OpenTelemetry openTelemetry, KafkaTelemetryConfiguration kafkaTelemetryConfiguration, Collection<KafkaTelemetryConsumerTracingFilter> consumerTracingFilters, Collection<KafkaTelemetryProducerTracingFilter> producerTracingFilters)

Method Summary

Modifier and Type	Method	Description
KafkaTelemetryBuilder	addConsumerAttributesExtractors(io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor<io.opentelemetry.instrumentation.kafka.internal.KafkaProcessRequest,Void> extractor)
KafkaTelemetryBuilder	addProducerAttributesExtractors(io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor<io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest,org.apache.kafka.clients.producer.RecordMetadata> extractor)
KafkaTelemetry	build()
void	setCaptureExperimentalSpanAttributes(boolean captureExperimentalSpanAttributes)
void	setPropagationEnabled(boolean propagationEnabled)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaTelemetryBuilder

public KafkaTelemetryBuilder(io.opentelemetry.api.OpenTelemetry openTelemetry,
 KafkaTelemetryConfiguration kafkaTelemetryConfiguration,
 Collection<KafkaTelemetryConsumerTracingFilter> consumerTracingFilters,
 Collection<KafkaTelemetryProducerTracingFilter> producerTracingFilters)

Method Details

addProducerAttributesExtractors

public KafkaTelemetryBuilder addProducerAttributesExtractors(io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor<io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest,org.apache.kafka.clients.producer.RecordMetadata> extractor)

addConsumerAttributesExtractors

public KafkaTelemetryBuilder addConsumerAttributesExtractors(io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor<io.opentelemetry.instrumentation.kafka.internal.KafkaProcessRequest,Void> extractor)

build

public KafkaTelemetry build()

setCaptureExperimentalSpanAttributes

public void setCaptureExperimentalSpanAttributes(boolean captureExperimentalSpanAttributes)

setPropagationEnabled

public void setPropagationEnabled(boolean propagationEnabled)