root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Replace Stream#collect with Stream#toList api from JDK 16 (#18655) 

Reviewers: Divij Vaidya <diviv@amazon.com>
This commit is contained in:
qingbozhang 2025-01-23 19:15:41 +08:00 committed by GitHub
parent 27552e7b11
commit a783dc69b9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java
View File

@ -357,7 +357,7 @@ public class LogLoader {
// segments that come before it
File[] files = dir.listFiles();
if (files == null) files = new File[0];
List<File> sortedFiles = Arrays.stream(files).filter(File::isFile).sorted().collect(Collectors.toList());
List<File> 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