[fix][broker]Close publishLimiter when disable it (apache#15520)

(cherry picked from commit e8c971a) (cherry picked from commit 761c42d)
datastax · May 23, 2022 · 1055ae3 · 1055ae3
1 parent aa7f208
commit 1055ae3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
@@ -1102,6 +1102,9 @@ public void updatePublishDispatcher() {
             }
         } else {
             log.info("Disabling publish throttling for {}", this.topic);
+            if (topicPublishRateLimiter != null) {
+                topicPublishRateLimiter.close();
+            }
             this.topicPublishRateLimiter = PublishRateLimiter.DISABLED_RATE_LIMITER;
             enableProducerReadForPublishRateLimiting();
         }