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 Details

  • 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