You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/05/20 15:06:04 UTC
[pulsar] 22/31: [fix][broker]Close publishLimiter when disable it (#15520)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 761c42d33efd3602d3a602bafb738e23c59e09ac
Author: Xiaoyu Hou <An...@gmail.com>
AuthorDate: Wed May 11 20:20:28 2022 +0800
[fix][broker]Close publishLimiter when disable it (#15520)
(cherry picked from commit e8c971a2f15d9fe79eb88f92c022216a0ca57f73)
---
.../src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java | 3 +++
1 file changed, 3 insertions(+)
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
index 852185d4919..a4983be4bd8 100644
--- 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 abstract class AbstractTopic implements Topic, TopicPolicyListener<TopicP
}
} else {
log.info("Disabling publish throttling for {}", this.topic);
+ if (topicPublishRateLimiter != null) {
+ topicPublishRateLimiter.close();
+ }
this.topicPublishRateLimiter = PublishRateLimiter.DISABLED_RATE_LIMITER;
enableProducerReadForPublishRateLimiting();
}