fix(spring-jakarta): Update consumer references and add reflection warning log

Update SentryKafkaRecordInterceptor and its test to reference
SentryProducerInterceptor instead of the removed
SentryKafkaProducerWrapper.

Add a warning log in SentryKafkaConsumerBeanPostProcessor when
reflection fails to read the existing RecordInterceptor, so users
know their custom interceptor may not be chained.

Co-Authored-By: Claude <noreply@anthropic.com>

Author: adinauer

sentry-spring-jakarta/src/main/java/io/sentry/spring/jakarta/kafka/SentryKafkaConsumerBeanPostProcessor.java

@@ -1,6 +1,7 @@
 package io.sentry.spring.jakarta.kafka;
 
 import io.sentry.ScopesAdapter;
+import io.sentry.SentryLevel;
 import java.lang.reflect.Field;
 import org.jetbrains.annotations.ApiStatus;
 import org.jetbrains.annotations.NotNull;
@@ -50,6 +51,15 @@ public final class SentryKafkaConsumerBeanPostProcessor
       field.setAccessible(true);
       return (RecordInterceptor<?, ?>) field.get(factory);
     } catch (NoSuchFieldException | IllegalAccessException e) {
+      ScopesAdapter.getInstance()
+          .getOptions()
+          .getLogger()
+          .log(
+              SentryLevel.WARNING,
+              "Unable to read existing recordInterceptor from "
+                  + "AbstractKafkaListenerContainerFactory via reflection. "
+                  + "If you had a custom RecordInterceptor, it may not be chained with Sentry's interceptor.",
+              e);
       return null;
     }
   }

sentry-spring-jakarta/src/main/java/io/sentry/spring/jakarta/kafka/SentryKafkaRecordInterceptor.java

@@ -141,7 +141,7 @@ private void continueTrace(
     }
 
     final @Nullable String enqueuedTimeStr =
-        headerValue(record, SentryKafkaProducerWrapper.SENTRY_ENQUEUED_TIME_HEADER);
+        headerValue(record, SentryProducerInterceptor.SENTRY_ENQUEUED_TIME_HEADER);
     if (enqueuedTimeStr != null) {
       try {
         final long enqueuedTime = Long.parseLong(enqueuedTimeStr);

sentry-spring-jakarta/src/test/kotlin/io/sentry/spring/jakarta/kafka/SentryKafkaRecordInterceptorTest.kt

@@ -74,7 +74,7 @@ class SentryKafkaRecordInterceptorTest {
     }
     enqueuedTime?.let {
       headers.add(
-        SentryKafkaProducerWrapper.SENTRY_ENQUEUED_TIME_HEADER,
+        SentryProducerInterceptor.SENTRY_ENQUEUED_TIME_HEADER,
         it.toString().toByteArray(StandardCharsets.UTF_8),
       )
     }