Fixes apache#7512 handle exception when policy is updated. (apache#7514)

sarvex · Jul 11, 2020 · a55a405 · a55a405
1 parent d97b57c
commit a55a405
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -1804,7 +1804,7 @@ public CompletableFuture<Void> onPoliciesUpdate(Policies data) {
             }
         });
         replicators.forEach((name, replicator) ->
-            replicator.getRateLimiter().get().onPoliciesUpdate(data)
+            replicator.getRateLimiter().ifPresent(rateLimiter -> rateLimiter.onPoliciesUpdate(data))
         );
         checkMessageExpiry();
         CompletableFuture<Void> replicationFuture = checkReplicationAndRetryOnFailure();