You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/03/01 03:12:35 UTC
[pulsar] 08/10: [pulsar-broker] Fix avg-messagePerEntry metrics for consumer (#14330)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 36689e26fee7039d448170f6377c1f5877967aad
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Sun Feb 27 17:36:51 2022 -0800
[pulsar-broker] Fix avg-messagePerEntry metrics for consumer (#14330)
(cherry picked from commit 7b10bd040e947497113db702ebcb2381d9dfe0fc)
---
.../src/main/java/org/apache/pulsar/broker/service/Consumer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
index 040fa20..3cf4cac 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
@@ -282,7 +282,7 @@ public class Consumer {
// calculate avg message per entry
int tmpAvgMessagesPerEntry = AVG_MESSAGES_PER_ENTRY.get(this);
- tmpAvgMessagesPerEntry = (int) Math.round(tmpAvgMessagesPerEntry * avgPercent
+ tmpAvgMessagesPerEntry = (int) Math.floor(tmpAvgMessagesPerEntry * avgPercent
+ (1 - avgPercent) * totalMessages / entries.size());
AVG_MESSAGES_PER_ENTRY.set(this, tmpAvgMessagesPerEntry);