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 <[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]>
---
.../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;