This is an automated email from the ASF dual-hosted git repository.

yubiao pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 28ddbf17808 [fix][broker] Fix NPE cause by topic publish rate limiter. 
(#20302)
28ddbf17808 is described below

commit 28ddbf1780864137546e10aa3e0fec6d86e8a739
Author: Shen Liu <[email protected]>
AuthorDate: Thu May 11 22:28:40 2023 +0800

    [fix][broker] Fix NPE cause by topic publish rate limiter. (#20302)
    
    Co-authored-by: druidliu <[email protected]>
    (cherry picked from commit 4b24c9e85ad534c2087063e7873eded4f9ab7a21)
---
 .../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 6245ce19eeb..8269dc0c3d1 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
@@ -115,7 +115,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