wip: spotless apply.

Author: vasantteja

instrumentation/kafka/kafka-connect-2.6/javaagent/build.gradle.kts

@@ -19,22 +19,21 @@ dependencies {
   library("org.apache.kafka:connect-api:2.6.0")
 
   testImplementation("org.apache.kafka:connect-runtime:2.6.0")
-
 }
 
 tasks {
   withType<Test>().configureEach {
     usesService(gradle.sharedServices.registrations["testcontainersBuildService"].service)
-    
+
     systemProperty("testLatestDeps", findProperty("testLatestDeps") as Boolean)
-    
+
     // Enable experimental span attributes and receive telemetry for comprehensive testing
     jvmArgs("-Dotel.instrumentation.kafka.experimental-span-attributes=true")
     jvmArgs("-Dotel.instrumentation.messaging.experimental.receive-telemetry.enabled=true")
     // Set timeout for integration tests with containers
     systemProperty("junit.jupiter.execution.timeout.default", "5m")
   }
-  
+
   withType<JavaCompile>().configureEach {
     options.compilerArgs.add("-Xlint:-deprecation")
   }

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

@@ -16,7 +16,8 @@
 @AutoService(InstrumentationModule.class)
 public class KafkaConnectInstrumentationModule extends InstrumentationModule {
 
-  private static final Logger logger = Logger.getLogger(KafkaConnectInstrumentationModule.class.getName());
+  private static final Logger logger =
+      Logger.getLogger(KafkaConnectInstrumentationModule.class.getName());
 
   public KafkaConnectInstrumentationModule() {
     super("kafka-connect", "kafka-connect-2.6");

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

@@ -14,11 +14,12 @@
 public final class KafkaConnectSingletons {
 
   private static final String INSTRUMENTATION_NAME = "io.opentelemetry.kafka-connect-2.6";
-  private static final TextMapPropagator PROPAGATOR = 
+  private static final TextMapPropagator PROPAGATOR =
       GlobalOpenTelemetry.get().getPropagators().getTextMapPropagator();
-  
-  private static final TextMapGetter<SinkRecord> SINK_RECORD_HEADER_GETTER = SinkRecordHeadersGetter.INSTANCE;
-  
+
+  private static final TextMapGetter<SinkRecord> SINK_RECORD_HEADER_GETTER =
+      SinkRecordHeadersGetter.INSTANCE;
+
   private static final Instrumenter<KafkaConnectTask, Void> INSTRUMENTER =
       Instrumenter.<KafkaConnectTask, Void>builder(
               GlobalOpenTelemetry.get(), INSTRUMENTATION_NAME, KafkaConnectTask::getSpanName)

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

@@ -6,8 +6,8 @@
 package io.opentelemetry.javaagent.instrumentation.kafkaconnect.v2_6;
 
 import static net.bytebuddy.matcher.ElementMatchers.hasSuperType;
-import static net.bytebuddy.matcher.ElementMatchers.named;
 import static net.bytebuddy.matcher.ElementMatchers.isPublic;
+import static net.bytebuddy.matcher.ElementMatchers.named;
 import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
 
 import io.opentelemetry.context.Context;
@@ -16,11 +16,11 @@
 import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
 import io.opentelemetry.javaagent.extension.instrumentation.TypeTransformer;
 import java.util.Collection;
+import java.util.logging.Logger;
 import net.bytebuddy.asm.Advice;
 import net.bytebuddy.description.type.TypeDescription;
 import net.bytebuddy.matcher.ElementMatcher;
 import org.apache.kafka.connect.sink.SinkRecord;
-import java.util.logging.Logger;
 
 public class SinkTaskInstrumentation implements TypeInstrumentation {
 
@@ -35,20 +35,19 @@ public ElementMatcher<TypeDescription> typeMatcher() {
   @Override
   public void transform(TypeTransformer transformer) {
     logger.info("KafkaConnect: transform() called - applying put() advice");
-    
+
     // Add advice to constructor to see what classes we're instrumenting
     transformer.applyAdviceToMethod(
-        named("<init>"),
-        SinkTaskInstrumentation.class.getName() + "$ConstructorAdvice");
-        
+        named("<init>"), SinkTaskInstrumentation.class.getName() + "$ConstructorAdvice");
+
     transformer.applyAdviceToMethod(
         named("put").and(takesArgument(0, Collection.class)).and(isPublic()),
         SinkTaskInstrumentation.class.getName() + "$SinkTaskPutAdvice");
   }
 
   @SuppressWarnings("unused")
   public static class ConstructorAdvice {
-    
+
     public static final Logger logger = Logger.getLogger(ConstructorAdvice.class.getName());
 
     @Advice.OnMethodExit(suppress = Throwable.class)
@@ -69,16 +68,18 @@ public static void onEnter(
         @Advice.Local("otelTask") KafkaConnectTask task,
         @Advice.Local("otelContext") Context context,
         @Advice.Local("otelScope") Scope scope) {
-      
+
       logger.info("KafkaConnect: SinkTask.put() called with " + records.size() + " records");
-      
-            Context parentContext = Java8BytecodeBridge.currentContext();
+
+      Context parentContext = Java8BytecodeBridge.currentContext();
 
       // Extract context from first record if available
       if (!records.isEmpty()) {
         SinkRecord firstRecord = records.iterator().next();
-        Context extractedContext = KafkaConnectSingletons.propagator()
-            .extract(parentContext, firstRecord, KafkaConnectSingletons.sinkRecordHeaderGetter());
+        Context extractedContext =
+            KafkaConnectSingletons.propagator()
+                .extract(
+                    parentContext, firstRecord, KafkaConnectSingletons.sinkRecordHeaderGetter());
         parentContext = extractedContext;
       }
 
@@ -87,7 +88,7 @@ public static void onEnter(
         logger.info("KafkaConnect: Instrumenter shouldStart returned false");
         return;
       }
-      
+
       context = KafkaConnectSingletons.instrumenter().start(parentContext, task);
       scope = context.makeCurrent();
       logger.info("KafkaConnect: Started span");
@@ -99,7 +100,7 @@ public static void onExit(
         @Advice.Local("otelTask") KafkaConnectTask task,
         @Advice.Local("otelContext") Context context,
         @Advice.Local("otelScope") Scope scope) {
-      
+
       if (scope == null) {
         logger.info("KafkaConnect: Scope is null, exiting");
         return;
@@ -108,7 +109,5 @@ public static void onExit(
       KafkaConnectSingletons.instrumenter().end(context, task, null, throwable);
       logger.info("KafkaConnect: Span ended");
     }
-    
-
   }
 }