diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
index c1d0977a1..fab94065a 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
@@ -1220,7 +1220,8 @@ public class KafkaMessageChannelBinder extends
 				List<ConsumerRecord<Object, Object>> records;
 				if (!properties.isBatchMode()) {
 					ConsumerRecord<Object, Object> record = StaticMessageHeaderAccessor.getSourceData(message);
-					records = List.of(Objects.requireNonNull(record));
+					records = new ArrayList<>();
+					records.add(Objects.requireNonNull(record));
 				}
 				else {
 					records = StaticMessageHeaderAccessor.getSourceData(message);