diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java index 8eafa5d574332..4b965fdaf7f3e 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java @@ -70,7 +70,7 @@ public BacklogQuota getBacklogQuota(String namespace, String policyPath) { .map(p -> p.backlog_quota_map.getOrDefault(BacklogQuotaType.destination_storage, defaultQuota)) .orElse(defaultQuota); } catch (Exception e) { - log.error("Failed to read policies data, will apply the default backlog quota: namespace={}", namespace, e); + log.warn("Failed to read policies data, will apply the default backlog quota: namespace={}", namespace, e); return this.defaultQuota; } } @@ -87,7 +87,7 @@ public BacklogQuota getBacklogQuota(TopicName topicName) { .map(map -> map.get(BacklogQuotaType.destination_storage.name())) .orElseGet(() -> getBacklogQuota(topicName.getNamespace(),policyPath)); } catch (Exception e) { - log.error("Failed to read policies data, will apply the default backlog quota: topicName={}", topicName, e); + log.warn("Failed to read topic policies data, will apply the namespace backlog quota: topicName={}", topicName, e); } return getBacklogQuota(topicName.getNamespace(),policyPath); }