[ISSUE #6587] fix getMax() in SparseConsumeQueue

Co-authored-by: guyinyou <[email protected]>
apache · Apr 14, 2023 · d3a8fe0 · d3a8fe0
1 parent d34a28b
commit d3a8fe0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java b/store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java
@@ -330,7 +330,7 @@ private <T> T getMax(MappedFile mappedFile, Function<ByteBuffer, T> function) {
             short batchSize = byteBuffer.getShort();
             if (offset >= 0 && size > 0 && msgBaseOffset >= 0 && batchSize > 0) {
                 byteBuffer.position(i);     //reset position
-                return function.apply(byteBuffer);
+                return function.apply(byteBuffer.slice());
             }
         }