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;
     }
 

Reply via email to