Skip to content

Commit 90da67f

Browse files
committed
use immutable list instead
1 parent c04aae2 commit 90da67f

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2247,7 +2247,7 @@ private List<ConsumerRecord<K, V>> createRecordList(final ConsumerRecords<K, V>
22472247
recordsArray[index] = iterator.next();
22482248
index += 1;
22492249
}
2250-
return Arrays.asList(recordsArray);
2250+
return List.of(recordsArray);
22512251
}
22522252

22532253
/**

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616

1717
package org.springframework.kafka.listener.adapter;
1818

19-
import java.util.Arrays;
2019
import java.util.List;
2120

2221
import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -54,7 +53,7 @@ public interface RecordFilterStrategy<K, V> {
5453
@SuppressWarnings("unchecked")
5554
default List<ConsumerRecord<K, V>> filterBatch(List<ConsumerRecord<K, V>> records) {
5655
var recordsArray = records.stream().filter(record -> !this.filter(record)).toArray(ConsumerRecord[]::new);
57-
return Arrays.asList(recordsArray);
56+
return List.of(recordsArray);
5857
}
5958

6059
/**

0 commit comments

Comments
 (0)