Skip to content

feat(spring-jakarta): [Queue Instrumentation 4] Add Kafka consumer instrumentation #5255

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
adinauer wants to merge 6 commits into
base: feat/queue-instrumentation-producer
Choose a base branch
from
Open

feat(spring-jakarta): [Queue Instrumentation 4] Add Kafka consumer instrumentation #5255

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
6099047
feat(spring-jakarta): Add Kafka consumer instrumentation
adinauer Apr 1, 2026
1f00027
changelog
adinauer Apr 1, 2026
2b74bab
Merge branch 'feat/queue-instrumentation-producer' into feat/queue-in…
adinauer Apr 9, 2026
be3a2ba
fix(spring-jakarta): Update consumer references and add reflection wa…
adinauer Apr 9, 2026
6450f63
Merge branch 'feat/queue-instrumentation-producer' into feat/queue-in…
adinauer Apr 9, 2026
f92f47c
fix(spring-jakarta): Initialize Sentry in consumer test, fix API file…
adinauer Apr 9, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
fix(spring-jakarta): Initialize Sentry in consumer test, fix API file… 
… ordering

Add initForTest/close to SentryKafkaRecordInterceptorTest to fix NPE
from TransactionContext constructor requiring initialized Sentry.

Regenerate API file to fix alphabetical ordering of
SentryProducerInterceptor entry.

Co-Authored-By: Claude <noreply@anthropic.com>
  • Loading branch information
@adinauer @claude
adinauer and claude committed Apr 9, 2026
commit f92f47c91c094e1da53ceca68e9bf479c83ce356
16 changes: 8 additions & 8 deletions sentry-spring-jakarta/api/sentry-spring-jakarta.api
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -256,14 +256,6 @@ public final class io/sentry/spring/jakarta/kafka/SentryKafkaProducerBeanPostPro
public fun postProcessAfterInitialization (Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
}

public final class io/sentry/spring/jakarta/kafka/SentryProducerInterceptor : org/apache/kafka/clients/producer/ProducerInterceptor {
public fun <init> (Lio/sentry/IScopes;)V
public fun close ()V
public fun configure (Ljava/util/Map;)V
public fun onAcknowledgement (Lorg/apache/kafka/clients/producer/RecordMetadata;Ljava/lang/Exception;)V
public fun onSend (Lorg/apache/kafka/clients/producer/ProducerRecord;)Lorg/apache/kafka/clients/producer/ProducerRecord;
}

public final class io/sentry/spring/jakarta/kafka/SentryKafkaRecordInterceptor : org/springframework/kafka/listener/RecordInterceptor {
public fun <init> (Lio/sentry/IScopes;)V
public fun <init> (Lio/sentry/IScopes;Lorg/springframework/kafka/listener/RecordInterceptor;)V
Expand All @@ -273,6 +265,14 @@ public final class io/sentry/spring/jakarta/kafka/SentryKafkaRecordInterceptor :
public fun success (Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/apache/kafka/clients/consumer/Consumer;)V
}

public final class io/sentry/spring/jakarta/kafka/SentryProducerInterceptor : org/apache/kafka/clients/producer/ProducerInterceptor {
public fun <init> (Lio/sentry/IScopes;)V
public fun close ()V
public fun configure (Ljava/util/Map;)V
public fun onAcknowledgement (Lorg/apache/kafka/clients/producer/RecordMetadata;Ljava/lang/Exception;)V
public fun onSend (Lorg/apache/kafka/clients/producer/ProducerRecord;)Lorg/apache/kafka/clients/producer/ProducerRecord;
}

public class io/sentry/spring/jakarta/opentelemetry/SentryOpenTelemetryAgentWithoutAutoInitConfiguration {
public fun <init> ()V
public fun sentryOpenTelemetryOptionsConfiguration ()Lio/sentry/Sentry$OptionsConfiguration;
Expand Down
9 changes: 9 additions & 0 deletions ...akarta/src/test/kotlin/io/sentry/spring/jakarta/kafka/SentryKafkaRecordInterceptorTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,11 +3,14 @@ package io.sentry.spring.jakarta.kafka
import io.sentry.BaggageHeader
import io.sentry.IScopes
import io.sentry.ISentryLifecycleToken
import io.sentry.Sentry
import io.sentry.SentryOptions
import io.sentry.SentryTraceHeader
import io.sentry.SentryTracer
import io.sentry.TransactionContext
import io.sentry.test.initForTest
import java.nio.charset.StandardCharsets
import kotlin.test.AfterTest
import kotlin.test.BeforeTest
import kotlin.test.Test
import kotlin.test.assertEquals
Expand All @@ -30,6 +33,7 @@ class SentryKafkaRecordInterceptorTest {

@BeforeTest
fun setup() {
initForTest { it.dsn = "https://key@sentry.io/proj" }
scopes = mock()
consumer = mock()
lifecycleToken = mock()
Expand All @@ -51,6 +55,11 @@ class SentryKafkaRecordInterceptorTest {
whenever(forkedScopes.startTransaction(any<TransactionContext>(), any())).thenReturn(tx)
}

@AfterTest
fun teardown() {
Sentry.close()
}

private fun createRecord(
topic: String = "my-topic",
headers: RecordHeaders = RecordHeaders(),
Expand Down
Loading