From 33b2e245e7cacbb5387d32a9ec293aa056cf5af9 Mon Sep 17 00:00:00 2001
From: k2la <mzq6mft9zz@gmail.com>
Date: Tue, 7 Jan 2020 10:37:42 +0900
Subject: [PATCH] add_backlogSize_in_topicStat (#5914)

(cherry picked from commit d1d5cf75bf01f4fdb3fc3b986d8599b688ce6f47)
---
 .../pulsar/broker/service/persistent/PersistentTopic.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index ab719252f8c1e..34cad879e6631 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -1442,7 +1442,8 @@ public void updateRates(NamespaceStats nsStats, NamespaceBundleStats bundleStats
         topicStatsStream.writePair("msgRateOut", topicStatsHelper.aggMsgRateOut);
         topicStatsStream.writePair("msgThroughputIn", topicStatsHelper.aggMsgThroughputIn);
         topicStatsStream.writePair("msgThroughputOut", topicStatsHelper.aggMsgThroughputOut);
-        topicStatsStream.writePair("storageSize", ledger.getEstimatedBacklogSize());
+        topicStatsStream.writePair("storageSize", ledger.getTotalSize());
+        topicStatsStream.writePair("backlogSize", ledger.getEstimatedBacklogSize());
         topicStatsStream.writePair("pendingAddEntriesCount", ((ManagedLedgerImpl) ledger).getPendingAddEntriesCount());
 
         nsStats.msgRateIn += topicStatsHelper.aggMsgRateIn;