You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2022/04/14 13:49:22 UTC
[pulsar] branch master updated: Fix logger lever from warn to debug when uancked threshold is limited (#14950)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new f9cfc3e7144 Fix logger lever from warn to debug when uancked threshold is limited (#14950)
f9cfc3e7144 is described below
commit f9cfc3e7144c75cf53672f6a66f38cac82a5104a
Author: xiaolong ran <xi...@tencent.com>
AuthorDate: Thu Apr 14 21:49:15 2022 +0800
Fix logger lever from warn to debug when uancked threshold is limited (#14950)
* Add rate logger for repo
Signed-off-by: xiaolongran <xi...@tencent.com>
* fix log info
Signed-off-by: xiaolongran <xi...@tencent.com>
* fix comments
Signed-off-by: xiaolongran <xi...@tencent.com>
---
.../service/persistent/PersistentDispatcherMultipleConsumers.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
index 0210ec699f8..fbfb09b24a5 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -260,8 +260,10 @@ public class PersistentDispatcherMultipleConsumers extends AbstractDispatcherMul
topic.getBrokerService().executor().execute(() -> readMoreEntries());
}
} else if (BLOCKED_DISPATCHER_ON_UNACKMSG_UPDATER.get(this) == TRUE) {
- log.warn("[{}] Dispatcher read is blocked due to unackMessages {} reached to max {}", name,
- totalUnackedMessages, topic.getMaxUnackedMessagesOnSubscription());
+ if (log.isDebugEnabled()) {
+ log.debug("[{}] Dispatcher read is blocked due to unackMessages {} reached to max {}", name,
+ totalUnackedMessages, topic.getMaxUnackedMessagesOnSubscription());
+ }
} else if (!havePendingRead) {
if (log.isDebugEnabled()) {
log.debug("[{}] Schedule read of {} messages for {} consumers", name, messagesToRead,