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
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionGetter for attributePrefix.Getter for captured headers set.Getter for excludedTopics.Getter for includedTopics.boolean
Getter for captured headers set.boolean
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.
-
Field Details
-
PREFIX
The default prefix used for Kafka Telemetry configuration.- See Also:
-
ALL_HEADERS
Value to capture all headers as span attributes.- See Also:
-
-
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
Getter for captured headers set.- Returns:
- capturedHeaders
-
setCapturedHeaders
Setter for captured headers set.- Parameters:
capturedHeaders
- capturedHeaders set
-
getIncludedTopics
Getter for includedTopics.- Returns:
- includedTopics
-
setIncludedTopics
Setter for included topics set.- Parameters:
includedTopics
- includedTopics set
-
getExcludedTopics
Getter for excludedTopics.- Returns:
- excludedTopics
-
setExcludedTopics
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
Getter for attributePrefix.- Returns:
- attributePrefix
-
setAttributePrefix
Setter for attributePrefix.- Parameters:
attributePrefix
- attributePrefix set
-