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;