updates.

apache · Mar 7, 2022 · dc2869c · dc2869c
1 parent d9f2c68
commit dc2869c
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
@@ -3032,7 +3032,7 @@ public void onUpdate(TopicPolicies policies) {
                         subscribeRateLimiter.onSubscribeRateUpdate(getSubscribeRate()));
             }
 
-            checkReplicationAndRetryOnFailure().thenAccept(__ -> {
+            checkReplicationAndRetryOnFailure().whenComplete((v, ex) -> {
                 replicators.forEach((name, replicator) -> replicator.getRateLimiter()
                         .ifPresent(DispatchRateLimiter::updateDispatchRate));
             });