turns the simplest approach works best

Author: janeklb

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

@@ -16,7 +16,6 @@
 
 package org.springframework.kafka.listener;
 
-import java.lang.reflect.Array;
 import java.nio.ByteBuffer;
 import java.time.Duration;
 import java.util.AbstractMap.SimpleEntry;
@@ -2239,15 +2238,9 @@ protected void doInTransactionWithoutResult(TransactionStatus status) {
 		}
 
 		private List<ConsumerRecord<K, V>> createRecordList(final ConsumerRecords<K, V> records) {
-			Iterator<ConsumerRecord<K, V>> iterator = records.iterator();
-			@SuppressWarnings("unchecked") ConsumerRecord<K, V>[] recordsArray =
-					(ConsumerRecord<K, V>[]) Array.newInstance(ConsumerRecord.class, records.count());
-			int index = 0;
-			while (iterator.hasNext()) {
-				recordsArray[index] = iterator.next();
-				index += 1;
-			}
-			return Arrays.asList(recordsArray);
+			List<ConsumerRecord<K, V>> recordList = new ArrayList<>(records.count());
+			records.forEach(recordList::add);
+			return recordList;
 		}
 
 		/**

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordFilterStrategy.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2025 the original author or authors.
+ * Copyright 2016-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -16,7 +16,6 @@
 
 package org.springframework.kafka.listener.adapter;
 
-import java.util.Arrays;
 import java.util.List;
 
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -33,7 +32,6 @@
  *
  * @author Gary Russell
  * @author Sanghyeok An
- * @author Janek Lasocki-Biczysko
  */
 public interface RecordFilterStrategy<K, V> {
 
@@ -51,10 +49,9 @@ public interface RecordFilterStrategy<K, V> {
 	 * @return the filtered records.
 	 * @since 2.8
 	 */
-	@SuppressWarnings("unchecked")
 	default List<ConsumerRecord<K, V>> filterBatch(List<ConsumerRecord<K, V>> records) {
-		var recordsArray = records.stream().filter(record -> !this.filter(record)).toArray(ConsumerRecord[]::new);
-		return Arrays.asList(recordsArray);
+		records.removeIf(this::filter);
+		return records;
 	}
 
 	/**