Avoid warning logs on topic policies not present (#10785)

apache · Jun 2, 2021 · 707b3a4 · 707b3a4
1 parent 045841e
commit 707b3a4
Showing 1 changed file with 6 additions and 4 deletions.
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
@@ -82,10 +82,12 @@ public BacklogQuota getBacklogQuota(TopicName topicName) {
         }
 
         try {
-            return Optional.ofNullable(pulsar.getTopicPoliciesService().getTopicPolicies(topicName))
-                    .map(TopicPolicies::getBackLogQuotaMap)
-                    .map(map -> map.get(BacklogQuotaType.destination_storage.name()))
-                    .orElseGet(() -> getBacklogQuota(topicName.getNamespace(), policyPath));
+            if (pulsar.getTopicPoliciesService().cacheIsInitialized(topicName)) {
+                return Optional.ofNullable(pulsar.getTopicPoliciesService().getTopicPolicies(topicName))
+                        .map(TopicPolicies::getBackLogQuotaMap)
+                        .map(map -> map.get(BacklogQuotaType.destination_storage.name()))
+                        .orElseGet(() -> getBacklogQuota(topicName.getNamespace(), policyPath));
+            }
         } catch (Exception e) {
             log.warn("Failed to read topic policies data, will apply the namespace backlog quota: topicName={}",
                     topicName, e);