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 <[email protected]> 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; }
