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

[adinauer]

PR Stack (Queue Instrumentation)

• feat(core): Queue Instrumentation #5249
• feat(core): [Queue Instrumentation 1] Add enableQueueTracing option and messaging span data conventions #5250
• feat(samples): [Queue Instrumentation 2] Add Kafka to Spring Boot 3 sample app #5253
• feat(spring-jakarta): [Queue Instrumentation 3] Add Kafka producer instrumentation #5254
• feat(spring-jakarta): [Queue Instrumentation 4] Add Kafka consumer instrumentation #5255
• feat(spring-boot-jakarta): [Queue Instrumentation 5] Add Kafka queue auto-configuration #5259
• test(samples): [Queue Instrumentation 6] Add Kafka queue system tests #5260
• feat(samples): [Queue Instrumentation 7] Add Kafka to Spring Boot 3 OTel sample apps #5265
• fix(spring-boot-jakarta): [Queue Instrumentation 8] Disable Sentry Kafka spans when OTel is active #5274
• fix(spring-jakarta): [Queue Instrumentation 9] Clean up stale ThreadLocal context in Kafka consumer interceptor #5279
• fix(spring-jakarta): [Queue Instrumentation 10] Fork root scopes and skip when OTel is active in Kafka consumer #5280
• fix(spring-jakarta): [Queue Instrumentation 11] Guard entire span lifecycle in Kafka producer interceptor #5281
• fix(spring-jakarta): [Queue Instrumentation 12] Add Kafka retry count attribute #5282
• fix(spring-jakarta): [Queue Instrumentation 13] Align enqueue time with Python #5283
• ref(kafka): [Queue Instrumentation 14] Extract sentry-kafka module #5288
• feat(samples): [Queue Instrumentation 15] Add opt-in Kafka console e2e coverage #5289
• fix(test): [Queue Instrumentation 16] Enable Kafka profile in system runner #5291
• feat(kafka): [Queue Instrumentation 17] Add manual consumer tracing helper #5312
• ref(samples): [Queue Instrumentation 18] Move Kafka sources into queues.kafka package #5313
• ref(samples): [Queue Instrumentation 19] Drop Kafka auto-config exclude from Spring Boot samples #5314
• ref(kafka): [Queue Instrumentation 20] Log Kafka instrumentation failures #5315
• fix(kafka): [Queue Instrumentation 21] Preserve third-party baggage on Kafka producer records #5316
• test(spring-boot-jakarta): [Queue Instrumentation 22] Cover spring-kafka class-absence gate #5318
• fix(spring-jakarta): [Queue Instrumentation 23] Install Kafka context before trace setup #5319
• fix(kafka): [Queue Instrumentation 24] Read all baggage headers on consumers #5320
• fix(kafka): [Queue Instrumentation 25] Finish producer spans on failures #5321
• fix(kafka): [Queue Instrumentation 26] Mark producer interceptor experimental #5322
• fix(spring-jakarta): [Queue Instrumentation 27] Delegate Kafka record thread-state hooks #5323
• test(samples): [Queue Instrumentation 28] Cover OTel Jakarta Kafka coexistence in CI #5324
• fix(spring-jakarta): [Queue Instrumentation 29] Set body_size on Spring Kafka consumer transaction #5325
• test(spring-jakarta): [Queue Instrumentation 30] Cover Kafka record interceptor lifecycle edge cases #5327
• fix(kafka): [Queue Instrumentation 31] Write enqueued-time header as plain decimal #5328
• test(spring-boot-jakarta): [Queue Instrumentation 32] Filter OTel in Kafka auto-config negative tests #5330
• fix(otel): [Queue Instrumentation 34] Fix OTel messaging span mapping correctness #5337
• fix(kafka): [Queue Instrumentation 35] Inject trace headers even without active span #5338
• fix(kafka): [Queue Instrumentation 36] Avoid dropping customer interceptor #5341

---

{STACK_LIST}

📜 Description

Add Kafka consumer instrumentation to sentry-spring-jakarta:

• SentryKafkaRecordInterceptor — implements RecordInterceptor to create queue.process transactions for incoming Kafka records. Forks scopes per record for isolation (ISentryLifecycleToken lifecycle). Extracts sentry-trace and baggage headers for distributed tracing via continueTrace, and calculates messaging.message.receive.latency from the enqueued-time header. Composes with existing RecordInterceptor via delegation. Span lifecycle is managed through success/failure callbacks.
• SentryKafkaConsumerBeanPostProcessor — registers the interceptor on ConcurrentKafkaListenerContainerFactory beans.

💡 Motivation and Context

Consumer-side instrumentation is needed to create process transactions and continue the distributed trace from the producer.

💚 How did you test it?

Unit tests for SentryKafkaRecordInterceptor and SentryKafkaConsumerBeanPostProcessor.

📝 Checklist

• I added GH Issue ID & Linear ID
• I added tests to verify the changes.
• No new PII added or SDK only sends newly added PII if sendDefaultPII is enabled.
• I updated the docs if needed.
• I updated the wizard if needed.
• Review from the native team if needed.
• No breaking change or entry added to the changelog.
• No breaking change for hybrid SDKs or communicated to hybrid SDKs.

🔮 Next steps

⚠️ Merge this PR using a merge commit (not squash). Only the collection branch is squash-merged into main.

[github-actions]

Semver Impact of This PR

🟡 Minor (new features)

📋 Changelog Preview

This is how your changes will appear in the changelog.
Entries from this PR are highlighted with a left border (blockquote style).

---

New Features ✨

Spring Jakarta

• [Queue Instrumentation 4] Add Kafka consumer instrumentation by adinauer in #5255

• [Queue Instrumentation 3] Add Kafka producer instrumentation by adinauer in #5254

Other

• (core) [Queue Instrumentation 1] Add enableQueueTracing option and messaging span data conventions by adinauer in #5250
• (samples) [Queue Instrumentation 2] Add Kafka to Spring Boot 3 sample app by adinauer in #5253
• Add strict trace continuation support by giortzisg in #5136
• Sync file attachments to native by bitsandfoxes in #5211

Internal Changes 🔧

Deps

• Bump requests from 2.32.4 to 2.33.0 in the uv group across 1 directory by dependabot in #5237
• Bump github/codeql-action from 4.32.6 to 4.35.1 by dependabot in #5243

Other

• Add THIRD_PARTY_NOTICES.md for vendored third-party code by markushi in #5186

---

_{🤖 This preview updates automatically when you update the PR.}

[github-actions]

	Messages
📖	Do not forget to update Sentry-docs with your feature once the pull request gets approved.

Generated by 🚫 dangerJS against f92f47c

[sentry]

Sentry Build Distribution

App Name	App ID	Version	Configuration	Install Page
SDK Size	io.sentry.tests.size	8.37.1 (1)	release	Install Build

Configure sentry-android build distribution settings

[github-actions]

Performance metrics 🚀

	Plain	With Sentry	Diff
Startup time	390.41 ms	445.34 ms	54.93 ms
Size	0 B	0 B	0 B

Baseline results on branch: feat/queue-instrumentation-producer

Startup times

Revision	Plain	With Sentry	Diff
d439efd	323.43 ms	384.17 ms	60.73 ms
6d877aa	308.23 ms	348.66 ms	40.43 ms

App size

Revision	Plain	With Sentry	Diff
d439efd	0 B	0 B	0 B
6d877aa	0 B	0 B	0 B

Previous results on branch: feat/queue-instrumentation-consumer

Startup times

Revision	Plain	With Sentry	Diff
651abdc	250.50 ms	320.04 ms	69.54 ms
5858973	343.53 ms	436.53 ms	93.00 ms

App size

Revision	Plain	With Sentry	Diff
651abdc	0 B	0 B	0 B
5858973	0 B	0 B	0 B

[adinauer]

I investigated whether we should switch the consumer composition to Spring’s CompositeRecordInterceptor.

I don’t think we should for this case, because it is strictly weaker than our current wrapper behavior:

• CompositeRecordInterceptor is not exception-shielded. Unlike CompositeProducerInterceptor, it does plain delegate calls for intercept/success/failure/afterRecord/setupThreadState/clearThreadState.
• That means if a customer interceptor throws in success() or failure(), later delegates are skipped.
• Our current SentryKafkaRecordInterceptor(delegate) uses try/finally around delegate success/failure, so Sentry transaction/lifecycle-token cleanup still runs even when delegate code throws.

Given the ThreadLocal/lifecycle-token leak risk we just fixed, that finally guarantee is important and CompositeRecordInterceptor doesn’t provide it.

[cursor]

Cursor Bugbot has reviewed your changes and found 1 potential issue.

^{❌ Bugbot Autofix is OFF. To automatically fix reported issues with cloud agents, enable autofix in the Cursor dashboard.}

^{Reviewed by Cursor Bugbot for commit f92f47c. Configure here.}