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/02/16 01:16:03 UTC
[pulsar] 02/08: Remove log unacked msg. (#14246)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit da86d9d062fcb30d60d9026719fd51d86ec8fc75
Author: Jiwei Guo <te...@apache.org>
AuthorDate: Sat Feb 12 01:34:53 2022 +0800
Remove log unacked msg. (#14246)
(cherry picked from commit 78bfaa27d0fdd0c97b90f1671c44b5c459bb93c1)
---
.../src/main/java/org/apache/pulsar/broker/service/Consumer.java | 3 ---
1 file changed, 3 deletions(-)
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 846eb6e..00511f4 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
@@ -924,9 +924,6 @@ public class Consumer {
subscription.addUnAckedMessages(ackedMessages);
unackedMsgs = UNACKED_MESSAGES_UPDATER.addAndGet(consumer, ackedMessages);
}
- if (unackedMsgs < 0) {
- log.error("unackedMsgs is : {}, ackedMessages : {}, consumer : {}", unackedMsgs, ackedMessages, consumer);
- }
return unackedMsgs;
}