io.micronaut.tracing.opentelemetry.instrument.kafka

Class KafkaTelemetryConfiguration

java.lang.Object

io.micronaut.tracing.opentelemetry.instrument.kafka.KafkaTelemetryConfiguration

@Requires(property="otel.instrumentation.kafka.enabled",
          notEquals="false")
 @ConfigurationProperties(value="otel.instrumentation.kafka")
public class KafkaTelemetryConfiguration
extends java.lang.Object

Configuration properties for KafkaTelemetry.

Since:

5.0.0

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ALL_HEADERS Value to capture all headers as span attributes.
static java.lang.String	PREFIX The default prefix used for Kafka Telemetry configuration.

Constructor Summary

Constructors

Constructor and Description
KafkaTelemetryConfiguration()

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.String>	getCapturedHeaders() List of headers, which you want to add as span attributes.
boolean	isHeadersAsLists() If you want to set headers as lists, set "true".
void	setCapturedHeaders(java.util.Set<java.lang.String> capturedHeaders) Setter for captured headers set.
void	setHeadersAsLists(boolean headersAsLists) Setter for headersAsLists flag.

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final java.lang.String PREFIX

The default prefix used for Kafka Telemetry configuration.

See Also:

Constant Field Values

ALL_HEADERS

public static final java.lang.String ALL_HEADERS

Value to capture all headers as span attributes.

See Also:

Constant Field Values

Constructor Detail

KafkaTelemetryConfiguration

public KafkaTelemetryConfiguration()

Method Detail

isHeadersAsLists

public boolean isHeadersAsLists()

If you want to set headers as lists, set "true".

Returns:

headersAsLists flag

setHeadersAsLists

public void setHeadersAsLists(boolean headersAsLists)

Setter for headersAsLists flag.

Parameters:

headersAsLists - flag

getCapturedHeaders

public java.util.Set<java.lang.String> getCapturedHeaders()

List of headers, which you want to add as span attributes. By default, all headers will be added as span attributes. If you don't want to set any headers as attributes, just set it to `null` or an empty string.

Returns:

capturedHeaders set

setCapturedHeaders

public void setCapturedHeaders(java.util.Set<java.lang.String> capturedHeaders)

Setter for captured headers set.

Parameters:

capturedHeaders - capturedHeaders set