We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3814ab5 commit d28d0d7Copy full SHA for d28d0d7
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -3044,7 +3044,7 @@ private CompletableFuture<Void> updateSubscriptionsDispatcherRateLimiter() {
3044
subscriptionCheckFutures.add(FutureUtil.waitForAll(consumerCheckFutures).thenRun(() -> {
3045
Dispatcher dispatcher = sub.getDispatcher();
3046
if (dispatcher != null) {
3047
- dispatcher.getRateLimiter().ifPresent(DispatchRateLimiter::updateDispatchRate);
+ dispatcher.updateRateLimiter();
3048
}
3049
}));
3050
});
0 commit comments