You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/04/22 05:38:52 UTC
(pulsar) 03/10: [improve][broker] backlog quota exceed limit log replaced with `debug` (#22488)
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 <65...@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 {