Revert changes of PersistentTopic#getMessageTTL in apache#12339.

Jason918 · Jul 31, 2022 · ff5945a · ff5945a
1 parent d6f56f1
commit ff5945a
Showing 1 changed file with 2 additions and 4 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
@@ -2475,10 +2475,8 @@ private int getMessageTTL() throws Exception {
         TopicName name = TopicName.get(topic);
         TopicPolicies topicPolicies = getTopicPolicies(name);
         Policies policies = brokerService.pulsar().getConfigurationCache().policiesCache()
-                .getDataIfPresent(AdminResource.path(POLICIES, name.getNamespace()));
-        if (policies == null) {
-          throw new KeeperException.NoNodeException();
-        }
+                .get(AdminResource.path(POLICIES, TopicName.get(topic).getNamespace()))
+                .orElseThrow(() -> new KeeperException.NoNodeException());
         if (topicPolicies != null && topicPolicies.isMessageTTLSet()) {
             return topicPolicies.getMessageTTLInSeconds();
         }