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;

Reply via email to