From f395fa68373c7552ad18fb522da69197bf151669 Mon Sep 17 00:00:00 2001
From: coding <zanglei.zang@qq.com>
Date: Wed, 8 Dec 2021 17:14:26 +0800
Subject: [PATCH] [ISSUE #3601] Fix dledger put batch msg stats bug (#3600)

Co-authored-by: zanglei <zanglei@kuaishou.com>
---
 .../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 37886730c2..12b8ec7f87 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
@@ -629,7 +629,7 @@ public class DLedgerCommitLog extends CommitLog {
             PutMessageResult putMessageResult = new PutMessageResult(putMessageStatus, appendResult);
             if (putMessageStatus == PutMessageStatus.PUT_OK) {
                 // Statistics
-                storeStatsService.getSinglePutMessageTopicTimesTotal(messageExtBatch.getTopic()).add(1);
+                storeStatsService.getSinglePutMessageTopicTimesTotal(messageExtBatch.getTopic()).add(appendResult.getMsgNum());
                 storeStatsService.getSinglePutMessageTopicSizeTotal(messageExtBatch.getTopic()).add(appendResult.getWroteBytes());
             }
             return putMessageResult;