From 384e56e19b649de934b31a282a7d8f5c08bbacc2 Mon Sep 17 00:00:00 2001
From: zhaoyuhan <zhaoyuhan@xiaomi.com>
Date: Thu, 26 Dec 2024 20:39:50 +0800
Subject: [PATCH] fix use bufferSize not msgSize in dledger recover

---
 .../org/apache/rocketmq/store/dledger/DLedgerCommitLog.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
index 5f4ef08374c..e76c05cc341 100644
--- a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
@@ -348,7 +348,7 @@ private void dledgerRecoverAbnormally(long maxPhyOffsetOfConsumeQueue) throws Ro
             long mmapFileOffset = 0;
             while (true) {
                 DispatchRequest dispatchRequest = this.checkMessageAndReturnSize(byteBuffer, checkCRCOnRecover, checkDupInfo);
-                int size = dispatchRequest.getMsgSize();
+                int size = dispatchRequest.getBufferSize();
 
                 if (dispatchRequest.isSuccess()) {
                     if (size > 0) {