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

(cherry picked from commit e8c971a)
apache · May 25, 2022 · 42353c0 · 42353c0
1 parent 6fd31d1
commit 42353c0
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
@@ -956,6 +956,9 @@ protected void updatePublishDispatcher(PublishRate publishRate) {
             }
         } else {
             log.info("Disabling publish throttling for {}", this.topic);
+            if (topicPublishRateLimiter != null) {
+                topicPublishRateLimiter.close();
+            }
             this.topicPublishRateLimiter = PublishRateLimiter.DISABLED_RATE_LIMITER;
             enableProducerReadForPublishRateLimiting();
         }