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