SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removes use of List.of() not available in java 8

Browse Source
This commit is contained in:
spencergibb
2023-02-22 12:33:50 -05:00
parent 13bb288499
commit ca14b3542e
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

@@ -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);