./gradlew spotlessApply

Author: otelbot[bot]

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

@@ -130,7 +130,8 @@ public void testKafkaConnectMongoSinkTaskInstrumentation()
                         .hasLinksSatisfying(
                             links ->
                                 assertThat(links)
-                                    .isEmpty()), // Verify no span links since no traceparent header was injected
+                                    .isEmpty()), // Verify no span links since no traceparent header
+                // was injected
                 span ->
                     span.hasName("update " + DB_NAME + "." + COLLECTION_NAME)
                         .hasKind(SpanKind.CLIENT)

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

@@ -149,7 +149,8 @@ public void testKafkaConnectPostgresSinkTaskInstrumentation()
                         .hasLinksSatisfying(
                             links ->
                                 assertThat(links)
-                                    .isEmpty()), // Verify no span links since no traceparent header was injected
+                                    .isEmpty()), // Verify no span links since no traceparent header
+                // was injected
                 span ->
                     span.hasName("SELECT test")
                         .hasKind(SpanKind.CLIENT)
@@ -340,12 +341,12 @@ public void testKafkaConnectPostgresSinkTaskMultiTopicInstrumentation() throws I
                       .filter(
                           span ->
                               ((span.getName().contains(topicName1)
-                                      || span.getName().contains(topicName2)
-                                      || span.getName().contains(topicName3))
-                                  || (span.getName().contains("[")
-                                      && span.getName().contains("]")
-                                      && span.getName().contains("process"))
-                                  || span.getName().equals("unknown process"))
+                                          || span.getName().contains(topicName2)
+                                          || span.getName().contains(topicName3))
+                                      || (span.getName().contains("[")
+                                          && span.getName().contains("]")
+                                          && span.getName().contains("process"))
+                                      || span.getName().equals("unknown process"))
                                   && span.getKind() == CONSUMER)
                       .count();
 
@@ -398,7 +399,8 @@ public void testKafkaConnectPostgresSinkTaskMultiTopicInstrumentation() throws I
                       .flatMap(trace -> trace.stream())
                       .anyMatch(
                           span ->
-                              span.getName().equals("unknown process") && span.getKind() == CONSUMER);
+                              span.getName().equals("unknown process")
+                                  && span.getKind() == CONSUMER);
 
               assertThat(hasMultiTopicSpan || hasIndividualSpans || hasUnknownProcessSpan)
                   .as(
@@ -412,12 +414,12 @@ public void testKafkaConnectPostgresSinkTaskMultiTopicInstrumentation() throws I
                       .filter(
                           span ->
                               ((span.getName().contains(topicName1)
-                                      || span.getName().contains(topicName2)
-                                      || span.getName().contains(topicName3))
-                                  || (span.getName().contains("[")
-                                      && span.getName().contains("]")
-                                      && span.getName().contains("process"))
-                                  || span.getName().equals("unknown process"))
+                                          || span.getName().contains(topicName2)
+                                          || span.getName().contains(topicName3))
+                                      || (span.getName().contains("[")
+                                          && span.getName().contains("]")
+                                          && span.getName().contains("process"))
+                                      || span.getName().equals("unknown process"))
                                   && span.getKind() == CONSUMER
                                   && !span.getLinks().isEmpty())
                       .count();