fix(spring-boot-jakarta): Disable Sentry Kafka instrumentation when OTel is active

Skip registration of SentryKafkaProducerBeanPostProcessor and
SentryKafkaConsumerBeanPostProcessor when a Sentry OpenTelemetry
integration (agent or agentless) is on the classpath. OpenTelemetry
provides its own Kafka instrumentation, so Sentry's would create
duplicate spans.

Author: adinauer

sentry-spring-boot-jakarta/src/main/java/io/sentry/spring/boot/jakarta/SentryAutoConfiguration.java

@@ -252,6 +252,7 @@ static class SentryCacheConfiguration {
     @Configuration(proxyBeanMethods = false)
     @ConditionalOnClass(KafkaTemplate.class)
     @ConditionalOnProperty(name = "sentry.enable-queue-tracing", havingValue = "true")
+    @ConditionalOnMissingClass("io.sentry.opentelemetry.SentryAutoConfigurationCustomizerProvider")
     @Open
     static class SentryKafkaQueueConfiguration {
 

sentry-spring-boot-jakarta/src/test/kotlin/io/sentry/spring/boot/jakarta/SentryKafkaAutoConfigurationTest.kt

@@ -1,10 +1,12 @@
 package io.sentry.spring.boot.jakarta
 
+import io.sentry.opentelemetry.SentryAutoConfigurationCustomizerProvider
 import io.sentry.spring.jakarta.kafka.SentryKafkaConsumerBeanPostProcessor
 import io.sentry.spring.jakarta.kafka.SentryKafkaProducerBeanPostProcessor
 import kotlin.test.Test
 import org.assertj.core.api.Assertions.assertThat
 import org.springframework.boot.autoconfigure.AutoConfigurations
+import org.springframework.boot.test.context.FilteredClassLoader
 import org.springframework.boot.test.context.runner.ApplicationContextRunner
 
 class SentryKafkaAutoConfigurationTest {
@@ -24,25 +26,43 @@ class SentryKafkaAutoConfigurationTest {
         "sentry.debug=false",
       )
 
+  /** Hide the OTel customizer so conditions evaluate as "no OTel present". */
+  private val noOtelClassLoader =
+    FilteredClassLoader(SentryAutoConfigurationCustomizerProvider::class.java)
+
   @Test
   fun `registers Kafka BPPs when queue tracing is enabled`() {
-    contextRunner.withPropertyValues("sentry.enable-queue-tracing=true").run { context ->
-      assertThat(context).hasSingleBean(SentryKafkaProducerBeanPostProcessor::class.java)
-      assertThat(context).hasSingleBean(SentryKafkaConsumerBeanPostProcessor::class.java)
-    }
+    contextRunner
+      .withClassLoader(noOtelClassLoader)
+      .withPropertyValues("sentry.enable-queue-tracing=true")
+      .run { context ->
+        assertThat(context).hasSingleBean(SentryKafkaProducerBeanPostProcessor::class.java)
+        assertThat(context).hasSingleBean(SentryKafkaConsumerBeanPostProcessor::class.java)
+      }
   }
 
   @Test
   fun `does not register Kafka BPPs when queue tracing is disabled`() {
-    contextRunner.run { context ->
+    contextRunner.withClassLoader(noOtelClassLoader).run { context ->
       assertThat(context).doesNotHaveBean(SentryKafkaProducerBeanPostProcessor::class.java)
       assertThat(context).doesNotHaveBean(SentryKafkaConsumerBeanPostProcessor::class.java)
     }
   }
 
   @Test
   fun `does not register Kafka BPPs when queue tracing is explicitly false`() {
-    contextRunner.withPropertyValues("sentry.enable-queue-tracing=false").run { context ->
+    contextRunner
+      .withClassLoader(noOtelClassLoader)
+      .withPropertyValues("sentry.enable-queue-tracing=false")
+      .run { context ->
+        assertThat(context).doesNotHaveBean(SentryKafkaProducerBeanPostProcessor::class.java)
+        assertThat(context).doesNotHaveBean(SentryKafkaConsumerBeanPostProcessor::class.java)
+      }
+  }
+
+  @Test
+  fun `does not register Kafka BPPs when OpenTelemetry integration is present`() {
+    contextRunner.withPropertyValues("sentry.enable-queue-tracing=true").run { context ->
       assertThat(context).doesNotHaveBean(SentryKafkaProducerBeanPostProcessor::class.java)
       assertThat(context).doesNotHaveBean(SentryKafkaConsumerBeanPostProcessor::class.java)
     }