(pulsar) 03/10: [improve][broker] backlog quota exceed limit log replaced with `debug` (#22488)

[lhotari]

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

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

commit 8d0a412eb93ed11dc3fd8cf12ac1d69d1ef25fc5
Author: Mukesh Kumar <65598381+mukesh...@users.noreply.github.com>
AuthorDate: Fri Apr 12 22:07:28 2024 +0530

    [improve][broker] backlog quota exceed limit log replaced with `debug` 
(#22488)
    
    (cherry picked from commit b85730069ee4c5f96406a075e354d0592fdab434)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 29df6e78cd1..a76ac548e0c 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -3150,14 +3150,14 @@ public class PersistentTopic extends AbstractTopic 
implements Topic, AddEntryCal
             if ((retentionPolicy == 
BacklogQuota.RetentionPolicy.producer_request_hold
                     || retentionPolicy == 
BacklogQuota.RetentionPolicy.producer_exception)) {
                 if (backlogQuotaType == BacklogQuotaType.destination_storage 
&& isSizeBacklogExceeded()) {
-                    log.info("[{}] Size backlog quota exceeded. Cannot create 
producer [{}]", this.getName(),
+                    log.debug("[{}] Size backlog quota exceeded. Cannot create 
producer [{}]", this.getName(),
                             producerName);
                     return FutureUtil.failedFuture(new 
TopicBacklogQuotaExceededException(retentionPolicy));
                 }
                 if (backlogQuotaType == BacklogQuotaType.message_age) {
                     return checkTimeBacklogExceeded().thenCompose(isExceeded 
-> {
                         if (isExceeded) {
-                            log.info("[{}] Time backlog quota exceeded. Cannot 
create producer [{}]", this.getName(),
+                            log.debug("[{}] Time backlog quota exceeded. 
Cannot create producer [{}]", this.getName(),
                                     producerName);
                             return FutureUtil.failedFuture(new 
TopicBacklogQuotaExceededException(retentionPolicy));
                         } else {