./gradlew spotlessApply

Author: otelbot[bot]

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

@@ -24,17 +24,17 @@ public Collection<SinkRecord> getRecords() {
   }
 
   /**
-   * Returns the first record in the batch, used for extracting destination information.
-   * Note: Records in a batch can come from multiple topics, so this should only be used
-   * when you need a representative record, not for definitive topic information.
+   * Returns the first record in the batch, used for extracting destination information. Note:
+   * Records in a batch can come from multiple topics, so this should only be used when you need a
+   * representative record, not for definitive topic information.
    */
   public SinkRecord getFirstRecord() {
     return records.isEmpty() ? null : records.iterator().next();
   }
 
   /**
-   * Returns all unique topic names present in this batch of records.
-   * This provides accurate information about all topics being processed.
+   * Returns all unique topic names present in this batch of records. This provides accurate
+   * information about all topics being processed.
    */
   public Set<String> getTopics() {
     return records.stream()
@@ -43,9 +43,9 @@ public Set<String> getTopics() {
   }
 
   /**
-   * Returns a single topic name if all records are from the same topic,
-   * or a formatted string representing multiple topics if they differ.
-   * This is useful for span naming that needs to be concise but informative.
+   * Returns a single topic name if all records are from the same topic, or a formatted string
+   * representing multiple topics if they differ. This is useful for span naming that needs to be
+   * concise but informative.
    */
   public String getDestinationName() {
     Set<String> topics = getTopics();

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

@@ -417,7 +417,7 @@ public void testKafkaConnectMongoSinkTaskMultiTopicInstrumentation()
     String topicName1 = TOPIC_NAME + "-1";
     String topicName2 = TOPIC_NAME + "-2";
     String topicName3 = TOPIC_NAME + "-3";
-    
+
     // Setup Kafka Connect MongoDB Sink connector with multiple topics
     setupMongoSinkConnectorMultiTopic(topicName1, topicName2, topicName3);
 
@@ -437,9 +437,15 @@ public void testKafkaConnectMongoSinkTaskMultiTopicInstrumentation()
 
     try (KafkaProducer<String, String> producer = new KafkaProducer<>(props)) {
       // Send messages to different topics
-      producer.send(new ProducerRecord<>(topicName1, "key1", "{\"id\":1,\"name\":\"User1\",\"source\":\"topic1\"}"));
-      producer.send(new ProducerRecord<>(topicName2, "key2", "{\"id\":2,\"name\":\"User2\",\"source\":\"topic2\"}"));
-      producer.send(new ProducerRecord<>(topicName3, "key3", "{\"id\":3,\"name\":\"User3\",\"source\":\"topic3\"}"));
+      producer.send(
+          new ProducerRecord<>(
+              topicName1, "key1", "{\"id\":1,\"name\":\"User1\",\"source\":\"topic1\"}"));
+      producer.send(
+          new ProducerRecord<>(
+              topicName2, "key2", "{\"id\":2,\"name\":\"User2\",\"source\":\"topic2\"}"));
+      producer.send(
+          new ProducerRecord<>(
+              topicName3, "key3", "{\"id\":3,\"name\":\"User3\",\"source\":\"topic3\"}"));
       producer.flush();
     }
 
@@ -474,8 +480,11 @@ public void testKafkaConnectMongoSinkTaskMultiTopicInstrumentation()
 
     // Write resourceSpans to desktop file for inspection
     try {
-      java.nio.file.Path desktopPath = java.nio.file.Paths.get(System.getProperty("user.home"), "Desktop", "kafka-connect-multi-topic-spans.json");
-      java.nio.file.Files.write(desktopPath, tracesJson.getBytes(java.nio.charset.StandardCharsets.UTF_8));
+      java.nio.file.Path desktopPath =
+          java.nio.file.Paths.get(
+              System.getProperty("user.home"), "Desktop", "kafka-connect-multi-topic-spans.json");
+      java.nio.file.Files.write(
+          desktopPath, tracesJson.getBytes(java.nio.charset.StandardCharsets.UTF_8));
       System.out.println("✅ Wrote resourceSpans to: " + desktopPath.toString());
     } catch (Exception e) {
       System.err.println("❌ Failed to write spans to desktop: " + e.getMessage());
@@ -484,7 +493,8 @@ public void testKafkaConnectMongoSinkTaskMultiTopicInstrumentation()
     // Extract spans and verify multi-topic span naming
     MultiTopicTracingData tracingData;
     try {
-      tracingData = deserializeAndExtractMultiTopicSpans(tracesJson, topicName1, topicName2, topicName3);
+      tracingData =
+          deserializeAndExtractMultiTopicSpans(tracesJson, topicName1, topicName2, topicName3);
     } catch (Exception e) {
       logger.error("Failed to deserialize and extract spans: {}", e.getMessage(), e);
       throw new AssertionError("Span deserialization failed", e);
@@ -495,7 +505,7 @@ public void testKafkaConnectMongoSinkTaskMultiTopicInstrumentation()
     assertThat(tracingData.kafkaConnectConsumerSpan)
         .as("Kafka Connect Consumer span should be found for multi-topic processing")
         .isNotNull();
-    
+
     // Assertion 2: Verify span name contains all topics in bracket format (order may vary)
     assertThat(tracingData.kafkaConnectConsumerSpan.name)
         .as("Span name should contain all topics in bracket format")
@@ -578,7 +588,8 @@ private static void setupMongoSinkConnectorMultiTopic(String... topicNames) thro
         "com.mongodb.kafka.connect.sink.processor.id.strategy.BsonOidStrategy");
 
     String payload =
-        MAPPER.writeValueAsString(ImmutableMap.of("name", CONNECTOR_NAME + "-multi", "config", configMap));
+        MAPPER.writeValueAsString(
+            ImmutableMap.of("name", CONNECTOR_NAME + "-multi", "config", configMap));
     given()
         .log()
         .headers()
@@ -816,8 +827,8 @@ private static TracingData deserializeAndExtractSpans(String tracesJson, String
   }
 
   /** Deserialize traces JSON and extract span information for multi-topic scenarios */
-  private static MultiTopicTracingData deserializeAndExtractMultiTopicSpans(String tracesJson, String... expectedTopicNames)
-      throws IOException {
+  private static MultiTopicTracingData deserializeAndExtractMultiTopicSpans(
+      String tracesJson, String... expectedTopicNames) throws IOException {
     ObjectMapper objectMapper = new ObjectMapper();
     JsonNode rootNode = objectMapper.readTree(tracesJson);
 
@@ -875,7 +886,7 @@ private static MultiTopicTracingData deserializeAndExtractMultiTopicSpans(String
                   break;
                 }
               }
-              
+
               if (containsExpectedTopics) {
                 kafkaConnectConsumerSpan =
                     new SpanInfo(spanName, traceId, spanId, parentSpanId, spanKind, scopeName);
@@ -912,9 +923,7 @@ private static class MultiTopicTracingData {
     final SpanLinkInfo extractedSpanLink;
 
     MultiTopicTracingData(
-        SpanInfo kafkaConnectConsumerSpan,
-        SpanInfo databaseSpan,
-        SpanLinkInfo extractedSpanLink) {
+        SpanInfo kafkaConnectConsumerSpan, SpanInfo databaseSpan, SpanLinkInfo extractedSpanLink) {
       this.kafkaConnectConsumerSpan = kafkaConnectConsumerSpan;
       this.databaseSpan = databaseSpan;
       this.extractedSpanLink = extractedSpanLink;