Fixes lint error.

Author: chickenchickenlove

spring-kafka/src/main/java/org/springframework/kafka/listener/DeliveryAttemptAwareRetryListener.java

@@ -23,10 +23,11 @@
 import org.apache.kafka.common.header.Header;
 import org.apache.kafka.common.header.Headers;
 import org.apache.kafka.common.header.internals.RecordHeader;
+
 import org.springframework.kafka.support.KafkaHeaders;
 
 /**
- * DeliveryAttemptAwareRetryListener class for {@link RetryListener} implementations.
+ * The DeliveryAttemptAwareRetryListener class for {@link RetryListener} implementations.
  * The DeliveryAttemptAwareRetryListener adds the {@link KafkaHeaders}.DELIVERY_ATTEMPT header
  * to the record's headers when batch records fail and are retried.
  * Note that DeliveryAttemptAwareRetryListener modifies the headers of the original record.

spring-kafka/src/test/java/org/springframework/kafka/listener/DeliveryAttemptAwareRetryListenerIntegrationTest.java

@@ -35,6 +35,7 @@
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.junit.jupiter.api.Test;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -128,7 +129,6 @@ void should_have_delivery_attempt_header_in_each_consumer_record_with_more_bigge
 		}
 	}
 
-
 	private Map<Integer, Integer> convertToMap(List<Header> headers) {
 		Map<Integer, Integer> map = new HashMap<>();
 		for (Header header : headers) {
@@ -139,6 +139,15 @@ private Map<Integer, Integer> convertToMap(List<Header> headers) {
 		return map;
 	}
 
+	private boolean awaitLatch(CountDownLatch latch) {
+		try {
+			return latch.await(60, TimeUnit.SECONDS);
+		}
+		catch (Exception e) {
+			fail(e.getMessage());
+			throw new RuntimeException(e);
+		}
+	}
 
 	static class TestTopicListener0 {
 		final List<Header> receivedHeaders = new ArrayList<>();
@@ -291,19 +300,9 @@ ConsumerFactory<String, String> consumerFactory() {
 			containerProperties.setDeliveryAttemptHeader(true);
 
 			return factory;
-		}
 
-
-	}
-
-	private boolean awaitLatch(CountDownLatch latch) {
-		try {
-			return latch.await(60, TimeUnit.SECONDS);
-		}
-		catch (Exception e) {
-			fail(e.getMessage());
-			throw new RuntimeException(e);
 		}
+
 	}
 
 }

spring-kafka/src/test/java/org/springframework/kafka/listener/DeliveryAttemptAwareRetryListenerTest.java

@@ -16,7 +16,7 @@
 
 package org.springframework.kafka.listener;
 
-import static org.assertj.core.api.Assertions.*;
+import static org.assertj.core.api.Assertions.assertThat;
 
 import java.nio.ByteBuffer;
 import java.util.HashMap;
@@ -28,6 +28,7 @@
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.header.Header;
 import org.junit.jupiter.api.Test;
+
 import org.springframework.kafka.support.KafkaHeaders;
 
 /**
@@ -38,7 +39,6 @@
 
 class DeliveryAttemptAwareRetryListenerTest {
 
-
 	@Test
 	void should_have_single_header_and_header_value_should_be_1() {
 		// Given