This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.10 by this push:
new 6bf6b333bba [fix][broker] Fix NPE when update topic policy. (#19875)
6bf6b333bba is described below
commit 6bf6b333bba9017366b76a0a3a75d5fd776a73e4
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 6e81509c830..ecb3ecd0c11 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;
@@ -171,4 +172,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;
+ }
}