reformat

Signed-off-by: Sergei Malafeev <sergei@malafeev.org>

opentracing-kafka-client/src/main/java/io/opentracing/contrib/kafka/TracingKafkaProducer.java

@@ -27,7 +27,6 @@
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 import java.util.function.BiFunction;
-
 import org.apache.kafka.clients.consumer.ConsumerGroupMetadata;
 import org.apache.kafka.clients.consumer.OffsetAndMetadata;
 import org.apache.kafka.clients.producer.Callback;

opentracing-kafka-client/src/main/java/io/opentracing/contrib/kafka/TracingKafkaUtils.java

@@ -49,7 +49,7 @@ public static SpanContext extractSpanContext(Headers headers, Tracer tracer) {
    * Inject Span Context to record headers
    *
    * @param spanContext Span Context
-   * @param headers record headers
+   * @param headers     record headers
    */
   public static void inject(SpanContext spanContext, Headers headers,
       Tracer tracer) {

opentracing-kafka-spring/src/main/java/io/opentracing/contrib/kafka/spring/TracingKafkaAspect.java

@@ -24,8 +24,8 @@
 import org.springframework.kafka.listener.MessageListenerContainer;
 
 /**
- * Wraps a {@link MessageListener} into a tracing proxy,
- * to support {@link org.springframework.kafka.annotation.KafkaListener} beans.
+ * Wraps a {@link MessageListener} into a tracing proxy, to support {@link
+ * org.springframework.kafka.annotation.KafkaListener} beans.
  * <p>
  * A port of Spring Sleuth implementation.
  */

opentracing-kafka-spring/src/test/java/io/opentracing/contrib/kafka/spring/Listener.java

@@ -13,14 +13,14 @@
  */
 package io.opentracing.contrib.kafka.spring;
 
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.notNullValue;
+
 import io.opentracing.mock.MockTracer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Component;
 
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.hamcrest.Matchers.notNullValue;
-
 @Component
 public class Listener {
 

opentracing-kafka-spring/src/test/java/io/opentracing/contrib/kafka/spring/TestConfiguration.java

@@ -13,7 +13,10 @@
  */
 package io.opentracing.contrib.kafka.spring;
 
+import static io.opentracing.contrib.kafka.spring.TracingSpringKafkaTest.embeddedKafka;
+
 import io.opentracing.mock.MockTracer;
+import java.util.Map;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
@@ -27,10 +30,6 @@
 import org.springframework.kafka.core.ProducerFactory;
 import org.springframework.kafka.test.utils.KafkaTestUtils;
 
-import java.util.Map;
-
-import static io.opentracing.contrib.kafka.spring.TracingSpringKafkaTest.embeddedKafka;
-
 @Configuration
 @EnableKafka
 @ComponentScan

opentracing-kafka-spring/src/test/java/io/opentracing/contrib/kafka/spring/TracingSpringKafkaTest.java

@@ -13,8 +13,16 @@
  */
 package io.opentracing.contrib.kafka.spring;
 
+import static org.awaitility.Awaitility.await;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.contains;
+import static org.hamcrest.Matchers.greaterThanOrEqualTo;
+
 import io.opentracing.mock.MockSpan;
 import io.opentracing.mock.MockTracer;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
 import org.hamcrest.BaseMatcher;
 import org.hamcrest.Description;
 import org.junit.Before;
@@ -27,15 +35,6 @@
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringRunner;
 
-import java.util.List;
-import java.util.concurrent.Callable;
-import java.util.concurrent.TimeUnit;
-
-import static org.awaitility.Awaitility.await;
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.hamcrest.Matchers.contains;
-import static org.hamcrest.Matchers.greaterThanOrEqualTo;
-
 @RunWith(SpringRunner.class)
 @ContextConfiguration(classes = {TestConfiguration.class})
 public class TracingSpringKafkaTest {
@@ -81,7 +80,8 @@ private SpanMatcher(String operationName) {
 
     @Override
     public boolean matches(Object actual) {
-      return actual instanceof MockSpan && operationName.equals(((MockSpan) actual).operationName());
+      return actual instanceof MockSpan && operationName
+          .equals(((MockSpan) actual).operationName());
     }
 
     @Override