refactor: check style

Signed-off-by: Chaedong Im <[email protected]>

Author: Chaedie

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

@@ -16,6 +16,11 @@
 
 package org.springframework.kafka.listener;
 
+import java.time.Duration;
+import java.util.*;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -25,11 +30,6 @@
 import org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter;
 import org.springframework.kafka.listener.adapter.RecordFilterStrategy;
 
-import java.time.Duration;
-import java.util.*;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.BDDMockito.given;
@@ -88,7 +88,7 @@ public void testRecordFilteredModeOnlyCommitsProcessedRecords() throws Interrupt
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When: Start the container and process records
 		container.start();
@@ -139,7 +139,7 @@ public void testRecordFilteredModeWithAllRecordsFiltered() throws InterruptedExc
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When
 		container.start();
@@ -201,7 +201,7 @@ public void testRecordFilteredModeWithMixedPartitions() throws InterruptedExcept
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When
 		container.start();

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

@@ -16,6 +16,11 @@
 
 package org.springframework.kafka.listener;
 
+import java.time.Duration;
+import java.util.*;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -25,11 +30,6 @@
 import org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter;
 import org.springframework.kafka.listener.adapter.RecordFilterStrategy;
 
-import java.time.Duration;
-import java.util.*;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyMap;
@@ -85,6 +85,8 @@ public void testCurrentRecordModeCommitsAllRecords() throws InterruptedException
 
 		Map<TopicPartition, List<ConsumerRecord<String, String>>> recordsMap = new HashMap<>();
 		recordsMap.put(tp, records);
+
+		@SuppressWarnings("deprecation")
 		ConsumerRecords<String, String> consumerRecords = new ConsumerRecords<>(recordsMap);
 
 		given(consumer.poll(any(Duration.class)))
@@ -135,6 +137,8 @@ public void testAllRecordsFilteredStillCommits() throws InterruptedException {
 
 		Map<TopicPartition, List<ConsumerRecord<String, String>>> recordsMap = new HashMap<>();
 		recordsMap.put(tp, records);
+
+		@SuppressWarnings("deprecation")
 		ConsumerRecords<String, String> consumerRecords = new ConsumerRecords<>(recordsMap);
 
 		given(consumer.poll(any(Duration.class)))
@@ -197,6 +201,8 @@ record -> record.value().contains("skip");
 		Map<TopicPartition, List<ConsumerRecord<String, String>>> recordsMap = new HashMap<>();
 		recordsMap.put(tp0, records.subList(0, 2));
 		recordsMap.put(tp1, records.subList(2, 5));
+
+		@SuppressWarnings("deprecation")
 		ConsumerRecords<String, String> consumerRecords = new ConsumerRecords<>(recordsMap);
 
 		given(consumer.poll(any(Duration.class)))
@@ -247,6 +253,8 @@ public void testCommitLogging() throws InterruptedException {
 
 		Map<TopicPartition, List<ConsumerRecord<String, String>>> recordsMap = new HashMap<>();
 		recordsMap.put(tp, records);
+
+		@SuppressWarnings("deprecation")
 		ConsumerRecords<String, String> consumerRecords = new ConsumerRecords<>(recordsMap);
 
 		given(consumer.poll(any(Duration.class)))
@@ -299,6 +307,8 @@ public void testAckDiscardedParameterBehavior() throws InterruptedException {
 
 		Map<TopicPartition, List<ConsumerRecord<String, String>>> recordsMap = new HashMap<>();
 		recordsMap.put(tp, records);
+
+		@SuppressWarnings("deprecation")
 		ConsumerRecords<String, String> consumerRecords = new ConsumerRecords<>(recordsMap);
 
 		given(consumer.poll(any(Duration.class)))