This is an automated email from the ASF dual-hosted git repository. technoboy pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push: new df96ff40e00 [fix][broker] Fix NPE cause by topic publish rate limiter. (#20302) df96ff40e00 is described below commit df96ff40e0011b114f2159e25007059fc78f6e70 Author: Shen Liu <liushen...@126.com> AuthorDate: Thu May 11 22:28:40 2023 +0800 [fix][broker] Fix NPE cause by topic publish rate limiter. (#20302) Co-authored-by: druidliu <druid...@tencent.com> --- .../src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 c1fcee4a059..8a76f615189 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 @@ -110,7 +110,7 @@ public abstract class AbstractTopic implements Topic, TopicPolicyListener<TopicP protected volatile Boolean isAllowAutoUpdateSchema; - protected volatile PublishRateLimiter topicPublishRateLimiter; + protected volatile PublishRateLimiter topicPublishRateLimiter = PublishRateLimiter.DISABLED_RATE_LIMITER; private final Object topicPublishRateLimiterLock = new Object(); protected volatile ResourceGroupPublishLimiter resourceGroupPublishLimiter;