From ca14b3542e5a7a94999059c36d5a557c01bc52c7 Mon Sep 17 00:00:00 2001 From: spencergibb Date: Wed, 22 Feb 2023 12:33:50 -0500 Subject: [PATCH] Removes use of List.of() not available in java 8 --- .../cloud/stream/binder/kafka/KafkaMessageChannelBinder.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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> records; if (!properties.isBatchMode()) { ConsumerRecord record = StaticMessageHeaderAccessor.getSourceData(message); - records = List.of(Objects.requireNonNull(record)); + records = new ArrayList<>(); + records.add(Objects.requireNonNull(record)); } else { records = StaticMessageHeaderAccessor.getSourceData(message);