This is an automated email from the ASF dual-hosted git repository.
nicoloboschi 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 b85730069ee [improve][broker] backlog quota exceed limit log replaced
with `debug` (#22488)
b85730069ee is described below
commit b85730069ee4c5f96406a075e354d0592fdab434
Author: Mukesh Kumar <[email protected]>
AuthorDate: Fri Apr 12 22:07:28 2024 +0530
[improve][broker] backlog quota exceed limit log replaced with `debug`
(#22488)
---
.../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 3ceecd7f4aa..3c9ab04d79a 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
@@ -3224,14 +3224,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 {
