Review fixes for kafka-connect-2.6:javaagent

otelbot[bot] · otelbot[bot] · commit bc5dc824af43 · 2026-04-21T22:16:45.000Z
Automated code review of instrumentation/kafka/kafka-connect-2.6/javaagent.
diff --git a/instrumentation/kafka/kafka-connect-2.6/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaconnect/v2_6/KafkaConnectBatchProcessSpanLinksExtractor.java b/instrumentation/kafka/kafka-connect-2.6/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaconnect/v2_6/KafkaConnectBatchProcessSpanLinksExtractor.java
@@ -25,7 +25,8 @@ final class KafkaConnectBatchProcessSpanLinksExtractor
   @Override
   public void extract(SpanLinksBuilder spanLinks, Context parentContext, KafkaConnectTask request) {
     for (SinkRecord record : request.getRecords()) {
-      singleRecordLinkExtractor.extract(spanLinks, parentContext, record);
+      // explicitly passing root to avoid linking the ambient context when propagation is off
+      singleRecordLinkExtractor.extract(spanLinks, Context.root(), record);
     }
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,8 @@ final class KafkaConnectBatchProcessSpanLinksExtractor`
`25`	`25`	`@Override`
`26`	`26`	`public void extract(SpanLinksBuilder spanLinks, Context parentContext, KafkaConnectTask request) {`
`27`	`27`	`for (SinkRecord record : request.getRecords()) {`
`28`		`- singleRecordLinkExtractor.extract(spanLinks, parentContext, record);`
	`28`	`+ // explicitly passing root to avoid linking the ambient context when propagation is off`
	`29`	`+ singleRecordLinkExtractor.extract(spanLinks, Context.root(), record);`
`29`	`30`	`}`
`30`	`31`	`}`
`31`	`32`	`}`