This is an automated email from the ASF dual-hosted git repository.
nicoloboschi pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 767f0b282a2 [improve][broker] backlog quota exceed limit log replaced
with `debug` (#22475)
767f0b282a2 is described below
commit 767f0b282a27581dfc16df9295ed01dd0df0a350
Author: Mukesh Kumar <[email protected]>
AuthorDate: Fri Apr 12 12:28:56 2024 +0530
[improve][broker] backlog quota exceed limit log replaced with `debug`
(#22475)
---
.../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 5bceed099c1..ee367750ad6 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
@@ -2938,14 +2938,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 {
