You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2024/04/10 08:51:33 UTC
(pulsar) branch master updated: [fix][broker] Fix message drop record in producer stat (#22458)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new cea1a9ba9b5 [fix][broker] Fix message drop record in producer stat (#22458)
cea1a9ba9b5 is described below
commit cea1a9ba9b576bf43f0a45ff8d65369b0f2bbb36
Author: zhangqian <50...@qq.com>
AuthorDate: Wed Apr 10 16:51:26 2024 +0800
[fix][broker] Fix message drop record in producer stat (#22458)
Co-authored-by: ceceezhang <ce...@tencent.com>
---
.../src/main/java/org/apache/pulsar/broker/service/Producer.java | 2 +-
1 file changed, 1 insertion(+), 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
index 7e4459505a5..9cfde67802b 100644
--- 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 class Producer {
}
if (this.isNonPersistentTopic) {
msgDrop.calculateRate();
- ((NonPersistentPublisherStatsImpl) stats).msgDropRate = msgDrop.getRate();
+ ((NonPersistentPublisherStatsImpl) stats).msgDropRate = msgDrop.getValueRate();
}
}