This is an automated email from the ASF dual-hosted git repository.

mmarshall pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.8 by this push:
     new 26baf84  Remove log unacked msg. (#14246)
26baf84 is described below

commit 26baf84959d2ff7a42324cd852dd80ac3ddda31f
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 678bdcf..9c75e11 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
@@ -913,9 +913,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