diff --git a/storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java b/storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java index 89780686995..285e9fb11f7 100644 --- a/storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java +++ b/storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java @@ -357,7 +357,7 @@ public class LogLoader { // segments that come before it File[] files = dir.listFiles(); if (files == null) files = new File[0]; - List sortedFiles = Arrays.stream(files).filter(File::isFile).sorted().collect(Collectors.toList()); + List sortedFiles = Arrays.stream(files).filter(File::isFile).sorted().toList(); for (File file : sortedFiles) { if (LogFileUtils.isIndexFile(file)) { // if it is an index file, make sure it has a corresponding .log file