Package 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("otel.instrumentation.kafka")
public class KafkaTelemetryConfiguration
extends Object

Configuration properties for KafkaTelemetry.

Since:

4.5.0

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
KafkaTelemetryConfiguration()

Method Summary

Modifier and Type	Method	Description
String	getAttributePrefix()	Getter for attributePrefix.
Set<String>	getCapturedHeaders()	Getter for captured headers set.
Set<String>	getExcludedTopics()	Getter for excludedTopics.
Set<String>	getIncludedTopics()	Getter for includedTopics.
boolean	isAttributeWithPrefix()	Getter for captured headers set.
boolean	isHeadersAsLists()	Getter for headersAsLists flag.
void	setAttributePrefix(String attributePrefix)	Setter for attributePrefix.
void	setAttributeWithPrefix(boolean attributeWithPrefix)	Setter for attributeWithPrefix flag.
void	setCapturedHeaders(Set<String> capturedHeaders)	Setter for captured headers set.
void	setExcludedTopics(Set<String> excludedTopics)	Setter for excluded topics set.
void	setHeadersAsLists(boolean headersAsLists)	Setter for headersAsLists flag.
void	setIncludedTopics(Set<String> includedTopics)	Setter for included topics set.

Methods inherited from class java.lang.Object

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

Field Details

PREFIX

public static final String PREFIX

The default prefix used for Kafka Telemetry configuration.

See Also:

• Constant Field Values

ALL_HEADERS

public static final String ALL_HEADERS

Value to capture all headers as span attributes.

See Also:

• Constant Field Values

Constructor Details

KafkaTelemetryConfiguration

public KafkaTelemetryConfiguration()

Method Details

isHeadersAsLists

public boolean isHeadersAsLists()

Getter for headersAsLists flag.

Returns:

headersAsLists

setHeadersAsLists

public void setHeadersAsLists(boolean headersAsLists)

Setter for headersAsLists flag.

Parameters:

headersAsLists - flag

getCapturedHeaders

public Set<String> getCapturedHeaders()

Getter for captured headers set.

Returns:

capturedHeaders

setCapturedHeaders

public void setCapturedHeaders(Set<String> capturedHeaders)

Setter for captured headers set.

Parameters:

capturedHeaders - capturedHeaders set

getIncludedTopics

public Set<String> getIncludedTopics()

Getter for includedTopics.

Returns:

includedTopics

setIncludedTopics

public void setIncludedTopics(Set<String> includedTopics)

Setter for included topics set.

Parameters:

includedTopics - includedTopics set

getExcludedTopics

public Set<String> getExcludedTopics()

Getter for excludedTopics.

Returns:

excludedTopics

setExcludedTopics

public void setExcludedTopics(Set<String> excludedTopics)

Setter for excluded topics set.

Parameters:

excludedTopics - excludedTopics set

isAttributeWithPrefix

public boolean isAttributeWithPrefix()

Getter for captured headers set.

Returns:

attributeWithPrefix

setAttributeWithPrefix

public void setAttributeWithPrefix(boolean attributeWithPrefix)

Setter for attributeWithPrefix flag.

Parameters:

attributeWithPrefix - attributeWithPrefix flag

getAttributePrefix

public String getAttributePrefix()

Getter for attributePrefix.

Returns:

attributePrefix

setAttributePrefix

public void setAttributePrefix(String attributePrefix)

Setter for attributePrefix.

Parameters:

attributePrefix - attributePrefix set