[fix][broker] Fix message drop record in producer stat (apache#22458)

Co-authored-by: ceceezhang <[email protected]>
poorbarcode · Apr 10, 2024 · cea1a9b · cea1a9b
1 parent fb5caeb
commit cea1a9b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java
@@ -749,7 +749,7 @@ public void updateRates() {
         }
         if (this.isNonPersistentTopic) {
             msgDrop.calculateRate();
-            ((NonPersistentPublisherStatsImpl) stats).msgDropRate = msgDrop.getRate();
+            ((NonPersistentPublisherStatsImpl) stats).msgDropRate = msgDrop.getValueRate();
         }
     }