diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java index 86320f9292468..634afccf6ac39 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java @@ -357,7 +357,10 @@ public double getLedgerSwitchLatencyAverageUsec() { @Override public long getStoredMessagesSize() { - return managedLedger.getTotalSize() * managedLedger.getConfig().getWriteQuorumSize(); + long totalSize = managedLedger.getTotalSize(); + long offloadedSize = managedLedger.getOffloadedSize(); + long bookieSize = totalSize - offloadedSize; + return bookieSize * managedLedger.getConfig().getWriteQuorumSize() + offloadedSize; } @Override