Cover Kafka ecosystem messaging v1.43 telemetry

[trask]

Depends on #19270.

Dependency baseline: cd9360e14660d61ce7739ca4a41d9e4de17e6bd6.
Review only: cd9360e14660d61ce7739ca4a41d9e4de17e6bd6..cac11bfe6b0bc12e4c0df68046406280eb5f61ba.

Exactly one Kafka ecosystem commit. Stable topology assertions cover producer/process chains plus separate linked poll traces, including receive-telemetry opt-out and receive-enabled retry/failure paths.

Validated locally with the full check lifecycle for Kafka Streams, Reactor Kafka, Vert.x Kafka 3.6/4/5 testing, Spring Kafka, and testing-common, plus repository-wide spotlessCheck. Spring Kafka stable receive-enabled coverage includes single/batch success and retry/failure topology with exact error.type, parent, and link assertions.

[opentelemetry-pr-dashboard]

Pull request dashboard status

Status last refreshed: 2026-07-22 16:49:38 UTC.

• Waiting on: Author
• Next step: Move out of draft to request review.

This automated status or its linked feedback items may be incorrect. If something looks wrong, please report it with the result you expected.

[Copilot]

Pull request overview

Adds Kafka messaging v1.43 preview coverage across downstream ecosystem integrations while retaining legacy assertions.

Changes:

• Adds staged testV3Preview Gradle tasks.
• Updates span names, kinds, attributes, and error assertions.
• Covers Kafka Streams, Reactor Kafka, Spring Kafka, and Vert.x Kafka variants.

Reviewed changes

Copilot reviewed 67 out of 67 changed files in this pull request and generated no comments.

Show a summary per file

File	Description
instrumentation/kafka/kafka-streams-0.11/javaagent/build.gradle.kts	Adds v3-preview testing.
instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/v0_11/KafkaStreamsDefaultTest.java	Adds dual-semconv assertions.
instrumentation/reactor/reactor-kafka-1.0/javaagent/build.gradle.kts	Adds v3-preview testing.
instrumentation/reactor/reactor-kafka-1.0/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/AbstractReactorKafkaTest.java	Updates messaging assertions.
instrumentation/spring/spring-kafka-2.7/javaagent/build.gradle.kts	Adds v3-preview testing.
instrumentation/spring/spring-kafka-2.7/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/spring/kafka/v2_7/SpringKafkaTest.java	Updates span and attribute coverage.
instrumentation/vertx/vertx-kafka-client-3.6/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/vertx/kafka/AbstractBatchRecordsNoReceiveTelemetryVertxKafkaTest.java	Adapts batch no-receive assertions.
instrumentation/vertx/vertx-kafka-client-3.6/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/vertx/kafka/AbstractBatchRecordsVertxKafkaTest.java	Adapts batch receive assertions.
instrumentation/vertx/vertx-kafka-client-3.6/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/vertx/kafka/AbstractSingleRecordNoReceiveTelemetryVertxKafkaTest.java	Adapts single-record no-receive assertions.
instrumentation/vertx/vertx-kafka-client-3.6/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/vertx/kafka/AbstractSingleRecordVertxKafkaTest.java	Adapts single-record receive assertions.
instrumentation/vertx/vertx-kafka-client-3.6/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/vertx/kafka/AbstractVertxKafkaTest.java	Centralizes semconv-aware helpers.
instrumentation/vertx/vertx-kafka-client-3.6/vertx-kafka-client-3.6-testing/build.gradle.kts	Adds v3-preview testing.
instrumentation/vertx/vertx-kafka-client-3.6/vertx-kafka-client-4-testing/build.gradle.kts	Adds v3-preview testing.
instrumentation/vertx/vertx-kafka-client-3.6/vertx-kafka-client-5-testing/build.gradle.kts	Adds v3-preview testing.

[Copilot]

Pull request overview

Copilot reviewed 69 out of 69 changed files in this pull request and generated no new comments.

[Copilot]

Pull request overview

Copilot reviewed 69 out of 69 changed files in this pull request and generated no new comments.

[Copilot]

Pull request overview

Copilot reviewed 69 out of 69 changed files in this pull request and generated 2 comments.

[Copilot]

Pull request overview

Copilot reviewed 69 out of 69 changed files in this pull request and generated no new comments.

[Copilot]

Pull request overview

Copilot reviewed 75 out of 75 changed files in this pull request and generated no new comments.

[Copilot]

Pull request overview

Copilot reviewed 75 out of 75 changed files in this pull request and generated 1 comment.

[Copilot]

Pull request overview

Copilot reviewed 75 out of 75 changed files in this pull request and generated no new comments.

[Copilot]

Pull request overview

Copilot reviewed 75 out of 75 changed files in this pull request and generated 1 comment.

Comments suppressed due to low confidence (1)

instrumentation/spring/spring-kafka-2.7/javaagent/build.gradle.kts:89

• [Testing] This stable-preview task only runs the default test source set and explicitly enables receive telemetry, so the existing testNoReceiveTelemetry suite is still exercised only under legacy messaging semconv. That leaves Spring Kafka's stable receive-opt-out topology untested despite the PR's stated stable no-receive coverage. Add a preview task using the testNoReceiveTelemetry source set with receive telemetry disabled, and update that suite's legacy-only span/attribute assertions for v1.43.

[Copilot]

Pull request overview

Copilot reviewed 77 out of 77 changed files in this pull request and generated no new comments.

[Copilot]

Pull request overview

Copilot reviewed 77 out of 77 changed files in this pull request and generated 3 comments.

[Copilot]

Pull request overview

Copilot reviewed 77 out of 77 changed files in this pull request and generated no new comments.