Skip to content

Commit dedd93d

Browse files
committed
./gradlew spotlessApply
1 parent e4dc787 commit dedd93d

File tree

2 files changed

+9
-29
lines changed

2 files changed

+9
-29
lines changed

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

Lines changed: 5 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,6 @@ class MongoKafkaConnectSinkTaskTest {
104104
private static MongoDBContainer mongoDB;
105105
private static int kafkaExposedPort;
106106

107-
108107
// Static methods
109108

110109
private static String getKafkaConnectUrl() {
@@ -797,16 +796,14 @@ private static TracingData deserializeAndExtractSpans(String tracesJson, String
797796
extractedSpanLink = new SpanLinkInfo(linkedTraceId, linkedSpanId);
798797
}
799798
} else if (scopeName.contains("mongo") && spanName.contains("testdb.person")) {
800-
databaseSpan =
801-
new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind);
799+
databaseSpan = new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind);
802800
}
803801
}
804802
}
805803
}
806804
}
807805

808-
return new TracingData(
809-
kafkaConnectConsumerSpan, databaseSpan, extractedSpanLink);
806+
return new TracingData(kafkaConnectConsumerSpan, databaseSpan, extractedSpanLink);
810807
}
811808

812809
/** Deserialize traces JSON and extract span information for multi-topic scenarios */
@@ -887,8 +884,7 @@ private static MultiTopicTracingData deserializeAndExtractMultiTopicSpans(
887884
}
888885
}
889886
} else if (scopeName.contains("mongo") && spanName.contains("testdb.person")) {
890-
databaseSpan =
891-
new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind);
887+
databaseSpan = new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind);
892888
}
893889
}
894890
}
@@ -919,9 +915,7 @@ private static class TracingData {
919915
final SpanLinkInfo extractedSpanLink;
920916

921917
TracingData(
922-
SpanInfo kafkaConnectConsumerSpan,
923-
SpanInfo databaseSpan,
924-
SpanLinkInfo extractedSpanLink) {
918+
SpanInfo kafkaConnectConsumerSpan, SpanInfo databaseSpan, SpanLinkInfo extractedSpanLink) {
925919
this.kafkaConnectConsumerSpan = kafkaConnectConsumerSpan;
926920
this.databaseSpan = databaseSpan;
927921
this.extractedSpanLink = extractedSpanLink;
@@ -947,12 +941,7 @@ private static class SpanInfo {
947941
final String parentSpanId;
948942
final String kind;
949943

950-
SpanInfo(
951-
String name,
952-
String traceId,
953-
String spanId,
954-
String parentSpanId,
955-
String kind) {
944+
SpanInfo(String name, String traceId, String spanId, String parentSpanId, String kind) {
956945
this.name = name;
957946
this.traceId = traceId;
958947
this.spanId = spanId;

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

Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -680,16 +680,14 @@ private static TracingData deserializeAndExtractSpans(String tracesJson, String
680680
|| spanName.contains("DELETE")
681681
|| spanName.contains("SELECT")
682682
|| spanName.contains(DB_TABLE_PERSON))) {
683-
databaseSpan =
684-
new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind);
683+
databaseSpan = new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind);
685684
}
686685
}
687686
}
688687
}
689688
}
690689

691-
return new TracingData(
692-
kafkaConnectConsumerSpan, databaseSpan, extractedSpanLink);
690+
return new TracingData(kafkaConnectConsumerSpan, databaseSpan, extractedSpanLink);
693691
}
694692

695693
// Helper class to hold all tracing data
@@ -699,9 +697,7 @@ private static class TracingData {
699697
final SpanLinkInfo extractedSpanLink;
700698

701699
TracingData(
702-
SpanInfo kafkaConnectConsumerSpan,
703-
SpanInfo databaseSpan,
704-
SpanLinkInfo extractedSpanLink) {
700+
SpanInfo kafkaConnectConsumerSpan, SpanInfo databaseSpan, SpanLinkInfo extractedSpanLink) {
705701
this.kafkaConnectConsumerSpan = kafkaConnectConsumerSpan;
706702
this.databaseSpan = databaseSpan;
707703
this.extractedSpanLink = extractedSpanLink;
@@ -715,12 +711,7 @@ private static class SpanInfo {
715711
final String parentSpanId;
716712
final String kind;
717713

718-
SpanInfo(
719-
String name,
720-
String traceId,
721-
String spanId,
722-
String parentSpanId,
723-
String kind) {
714+
SpanInfo(String name, String traceId, String spanId, String parentSpanId, String kind) {
724715
this.traceId = traceId;
725716
this.spanId = spanId;
726717
this.parentSpanId = parentSpanId;

0 commit comments

Comments
 (0)