refactor: replace deprecated code

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

Author: Chaedie

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

@@ -253,7 +253,7 @@ public void testRecordFilteredModeEfficiencyGains() throws InterruptedException
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When
 		container.start();
@@ -307,7 +307,7 @@ public void testRecordFilteredModeDoesNotBreakNormalProcessing() throws Interrup
 
 		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

@@ -89,7 +89,7 @@ public void testCurrentRecordModeCommitsAllRecords() throws InterruptedException
 
 		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 testAllRecordsFilteredStillCommits() throws InterruptedException {
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When: Start the container
 		container.start();
@@ -201,7 +201,7 @@ record -> record.value().contains("skip");
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When: Start container
 		container.start();
@@ -251,7 +251,7 @@ public void testCommitLogging() throws InterruptedException {
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		// When
 		container.start();
@@ -303,7 +303,7 @@ public void testAckDiscardedParameterBehavior() throws InterruptedException {
 
 		given(consumer.poll(any(Duration.class)))
 				.willReturn(consumerRecords)
-				.willReturn(new ConsumerRecords<>(Collections.emptyMap()));
+				.willReturn(ConsumerRecords.empty());
 
 		container.start();
 		assertThat(processedLatch.await(5, TimeUnit.SECONDS)).isTrue();