Skip to content

Commit cc9d32e

Browse files
committed
./gradlew spotlessApply
1 parent 55400e7 commit cc9d32e

File tree

3 files changed

+9
-6
lines changed

3 files changed

+9
-6
lines changed

instrumentation/kafka/kafka-connect-2.6/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaconnect/v2_6/SinkTaskInstrumentation.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,8 @@ public static void onEnter(
4848

4949
// For batch processing from multiple traces, use root context instead of extracting
5050
// from first record to avoid creating incorrect parent-child relationships.
51-
// Relationships are maintained through span links (see KafkaConnectBatchProcessSpanLinksExtractor)
51+
// Relationships are maintained through span links (see
52+
// KafkaConnectBatchProcessSpanLinksExtractor)
5253
Context parentContext = Java8BytecodeBridge.currentContext();
5354

5455
task = new KafkaConnectTask(records);

instrumentation/kafka/kafka-connect-2.6/testing/src/test/java/io/opentelemetry/instrumentation/kafkaconnect/v2_6/MongoKafkaConnectSinkTaskTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -419,7 +419,8 @@ public void testKafkaConnectMongoSinkTaskInstrumentation()
419419

420420
// Assertion 5: Verify Kafka Connect Consumer span has no parent (batch processing pattern)
421421
assertThat(tracingData.kafkaConnectConsumerSpan.parentSpanId)
422-
.as("Kafka Connect Consumer span should have no parent for batch processing from multiple traces")
422+
.as(
423+
"Kafka Connect Consumer span should have no parent for batch processing from multiple traces")
423424
.isNull();
424425
}
425426

@@ -553,7 +554,8 @@ public void testKafkaConnectMongoSinkTaskMultiTopicInstrumentation()
553554

554555
// Assertion 7: Verify Kafka Connect Consumer span has no parent (batch processing pattern)
555556
assertThat(tracingData.kafkaConnectConsumerSpan.parentSpanId)
556-
.as("Kafka Connect Consumer span should have no parent for batch processing from multiple traces")
557+
.as(
558+
"Kafka Connect Consumer span should have no parent for batch processing from multiple traces")
557559
.isNull();
558560
}
559561

instrumentation/kafka/kafka-connect-2.6/testing/src/test/java/io/opentelemetry/instrumentation/kafkaconnect/v2_6/PostgresKafkaConnectSinkTaskTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -446,7 +446,8 @@ public void testKafkaConnectPostgresSinkTaskInstrumentation()
446446

447447
// Assertion 5: Verify Kafka Connect Consumer span has no parent (batch processing pattern)
448448
assertThat(tracingData.kafkaConnectConsumerSpan.parentSpanId)
449-
.as("Kafka Connect Consumer span should have no parent for batch processing from multiple traces")
449+
.as(
450+
"Kafka Connect Consumer span should have no parent for batch processing from multiple traces")
450451
.isNull();
451452
}
452453

@@ -677,8 +678,7 @@ private static TracingData deserializeAndExtractSpans(String tracesJson, String
677678
if (scopeName.contains("kafka-connect")
678679
&& spanName.contains(expectedTopicName)
679680
&& spanKind.equals("SPAN_KIND_CONSUMER")) {
680-
kafkaConnectConsumerSpan =
681-
new SpanInfo(traceId, spanId, parentSpanId, spanKind);
681+
kafkaConnectConsumerSpan = new SpanInfo(traceId, spanId, parentSpanId, spanKind);
682682

683683
// Extract span link information for verification
684684
JsonNode linksArray = spanNode.get("links");

0 commit comments

Comments
 (0)