fix(kafka): Honor ignored producer span origins

adinauer · claude · adinauer · commit d2f4d8cb21a2 · 2026-04-20T14:46:14.000+02:00
Short-circuit the raw Kafka producer interceptor when its trace origin is
configured in ignoredSpanOrigins.

This lets customers disable the integration quickly without relying on the
later no-op span path, and keeps the interceptor from injecting tracing
headers when the origin is ignored.

Co-Authored-By: Claude &lt;noreply@anthropic.com&gt;
diff --git a/sentry-kafka/src/main/java/io/sentry/kafka/SentryKafkaProducerInterceptor.java b/sentry-kafka/src/main/java/io/sentry/kafka/SentryKafkaProducerInterceptor.java
@@ -9,6 +9,7 @@
 import io.sentry.SpanDataConvention;
 import io.sentry.SpanOptions;
 import io.sentry.SpanStatus;
+import io.sentry.util.SpanUtils;
 import io.sentry.util.TracingUtils;
 import java.nio.charset.StandardCharsets;
 import java.util.Map;
@@ -45,7 +46,7 @@ public SentryKafkaProducerInterceptor(
 
   @Override
   public @NotNull ProducerRecord<K, V> onSend(final @NotNull ProducerRecord<K, V> record) {
-    if (!scopes.getOptions().isEnableQueueTracing()) {
+    if (!scopes.getOptions().isEnableQueueTracing() || isIgnored()) {
       return record;
     }
 
@@ -81,6 +82,10 @@ public SentryKafkaProducerInterceptor(
   public void onAcknowledgement(
       final @Nullable RecordMetadata metadata, final @Nullable Exception exception) {}
 
+  private boolean isIgnored() {
+    return SpanUtils.isIgnored(scopes.getOptions().getIgnoredSpanOrigins(), traceOrigin);
+  }
+
   @Override
   public void close() {}
 
diff --git a/sentry-kafka/src/test/kotlin/io/sentry/kafka/SentryKafkaProducerInterceptorTest.kt b/sentry-kafka/src/test/kotlin/io/sentry/kafka/SentryKafkaProducerInterceptorTest.kt
@@ -90,6 +90,23 @@ class SentryKafkaProducerInterceptorTest {
     assertEquals(0, tx.spans.size)
   }
 
+  @Test
+  fun `does not create span when trace origin is ignored`() {
+    val tx = createTransaction()
+    options.setIgnoredSpanOrigins(listOf(SentryKafkaProducerInterceptor.TRACE_ORIGIN))
+    val interceptor = SentryKafkaProducerInterceptor<String, String>(scopes)
+    val record = ProducerRecord("my-topic", "key", "value")
+
+    interceptor.onSend(record)
+
+    assertEquals(0, tx.spans.size)
+    assertEquals(null, record.headers().lastHeader(SentryTraceHeader.SENTRY_TRACE_HEADER))
+    assertEquals(
+      null,
+      record.headers().lastHeader(SentryKafkaProducerInterceptor.SENTRY_ENQUEUED_TIME_HEADER),
+    )
+  }
+
   @Test
   fun `returns original record when no active span`() {
     whenever(scopes.span).thenReturn(null)
