[pulsar] branch master updated: Fix logger lever from warn to debug when uancked threshold is limited (#14950)

[rxl]

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 <xiaolong...@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 <xiaolong...@tencent.com>
    
    * fix log info
    
    Signed-off-by: xiaolongran <xiaolong...@tencent.com>
    
    * fix comments
    
    Signed-off-by: xiaolongran <xiaolong...@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,