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;
+ }
}