This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new b441b2f784b [fix][broker] Fix NPE when update topic policy. (#19875)
b441b2f784b is described below

commit b441b2f784b401e4b02a79a3db7f1120dd863895
Author: Jiwei Guo <[email protected]>
AuthorDate: Thu Mar 23 20:09:57 2023 +0800

    [fix][broker] Fix NPE when update topic policy. (#19875)
---
 .../java/org/apache/pulsar/common/policies/data/TopicPolicies.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java
 
b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java
index 07e4dff56bd..8eb01c3885b 100644
--- 
a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java
+++ 
b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java
@@ -20,6 +20,7 @@ package org.apache.pulsar.common.policies.data;
 
 import com.google.common.collect.Sets;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -183,4 +184,8 @@ public class TopicPolicies {
     public Set<String> getReplicationClustersSet() {
         return replicationClusters != null ? 
Sets.newTreeSet(this.replicationClusters) : null;
     }
+
+    public Map<String, SubscriptionPolicies> getSubscriptionPolicies() {
+        return subscriptionPolicies == null ? Collections.emptyMap() : 
subscriptionPolicies;
+    }
 }

Reply via email to