./gradlew spotlessApply

Author: otelbot[bot]

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetry.java

@@ -230,8 +230,7 @@ <K, V> ConsumerRecords<K, V> addTracing(
   public Map<String, ?> producerInterceptorConfigProperties() {
     Map<String, Object> config = new HashMap<>();
     config.put(
-        ProducerConfig.INTERCEPTOR_CLASSES_CONFIG,
-        TracingProducerInterceptor.class.getName());
+        ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, TracingProducerInterceptor.class.getName());
     config.put(
         TracingProducerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER,
         new KafkaTelemetrySupplier(this));
@@ -258,8 +257,7 @@ <K, V> ConsumerRecords<K, V> addTracing(
   public Map<String, ?> consumerInterceptorConfigProperties() {
     Map<String, Object> config = new HashMap<>();
     config.put(
-        ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG,
-        TracingConsumerInterceptor.class.getName());
+        ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG, TracingConsumerInterceptor.class.getName());
     config.put(
         TracingConsumerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER,
         new KafkaTelemetrySupplier(this));

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/TracingConsumerInterceptor.java

@@ -14,7 +14,6 @@
 import io.opentelemetry.instrumentation.api.internal.Timer;
 import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContext;
 import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContextUtil;
-import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaTelemetrySupplier;
 import java.util.Map;
 import java.util.Objects;
 import java.util.function.Supplier;

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/TracingProducerInterceptor.java

@@ -10,7 +10,6 @@
 import com.google.errorprone.annotations.CanIgnoreReturnValue;
 import io.opentelemetry.api.GlobalOpenTelemetry;
 import io.opentelemetry.instrumentation.api.internal.ConfigPropertiesUtil;
-import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaTelemetrySupplier;
 import java.util.Map;
 import java.util.Objects;
 import java.util.function.Supplier;

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/AbstractInterceptorsTest.java

@@ -13,10 +13,8 @@
 import java.nio.charset.StandardCharsets;
 import java.time.Duration;
 import java.util.Map;
-import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
-import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.RegisterExtension;

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetryInterceptorTest.java

@@ -127,19 +127,21 @@ void serializableConfig() throws IOException, ClassNotFoundException {
   private static void testSerialize(Map<String, Object> map)
       throws IOException, ClassNotFoundException {
     // Check that producer config has the supplier
-    Object producerSupplier = map.get(TracingProducerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER);
-    Object consumerSupplier = map.get(TracingConsumerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER);
-    
+    Object producerSupplier =
+        map.get(TracingProducerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER);
+    Object consumerSupplier =
+        map.get(TracingConsumerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER);
+
     KafkaTelemetrySupplier supplier = null;
     if (producerSupplier instanceof KafkaTelemetrySupplier) {
       supplier = (KafkaTelemetrySupplier) producerSupplier;
     } else if (consumerSupplier instanceof KafkaTelemetrySupplier) {
       supplier = (KafkaTelemetrySupplier) consumerSupplier;
     }
-    
+
     assertThat(supplier).isNotNull();
     assertThat(supplier.get()).isNotNull();
-    
+
     ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
     try (ObjectOutputStream outputStream = new ObjectOutputStream(byteOutputStream)) {
       outputStream.writeObject(map);