KAFKA-17513 Move LogSegmentsTest to storage module (#17173)

Reviewers: Chia-Ping Tsai <[email protected]>
apache · Sep 14, 2024 · 7a321f2 · 7a321f2
1 parent 61a8d65
commit 7a321f2
Show file tree

Hide file tree

Showing 4 changed files with 318 additions and 280 deletions.
diff --git a/core/src/test/scala/unit/kafka/log/LogSegmentsTest.scala b/core/src/test/scala/unit/kafka/log/LogSegmentsTest.scala
diff --git a/storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java b/storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java
@@ -18,6 +18,7 @@
 
 import org.apache.kafka.common.TopicPartition;
 
+import java.io.Closeable;
 import java.io.File;
 import java.io.IOException;
 import java.util.Collection;
@@ -34,7 +35,7 @@
  * This class encapsulates a thread-safe navigable map of LogSegment instances and provides the
  * required read and write behavior on the map.
  */
-public class LogSegments {
+public class LogSegments implements Closeable {
 
     private final TopicPartition topicPartition;
     /* the segments of the log with key being LogSegment base offset and value being a LogSegment */
@@ -102,6 +103,7 @@ public void clear() {
     /**
      * Close all segments.
      */
+    @Override
     public void close() throws IOException {
         for (LogSegment s : values())
             s.close();