diff --git a/fluss-server/src/main/java/org/apache/fluss/server/log/LogSegment.java b/fluss-server/src/main/java/org/apache/fluss/server/log/LogSegment.java
index c45c25e5c9..4c18b33c88 100644
--- a/fluss-server/src/main/java/org/apache/fluss/server/log/LogSegment.java
+++ b/fluss-server/src/main/java/org/apache/fluss/server/log/LogSegment.java
@@ -411,6 +411,9 @@ public long readNextOffset() throws IOException {
             return baseOffset;
         } else {
             Iterable<LogRecordBatch> batches = fetchData.getRecords().batches();
+            if (Iterables.isEmpty(batches)) {
+                return baseOffset;
+            }
             LogRecordBatch lastBatch = Iterables.getLast(batches);
             if (lastBatch != null) {
                 return lastBatch.nextLogOffset();