You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/04/22 05:20:10 UTC
(pulsar) 02/04: [improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore (#22519)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 8f5b825b7a979acf80ad88ad2a939357d3f1a970
Author: hanmz <gu...@tencent.com>
AuthorDate: Wed Apr 17 18:14:38 2024 +0800
[improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore (#22519)
(cherry picked from commit 1dd82a0affd6ec3686fa85d444c35bbbb4e9ce12)
---
.../src/main/java/org/apache/pulsar/broker/service/BrokerService.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 20de00370e1..fdc9e5b33fa 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -336,7 +336,9 @@ public class BrokerService implements Closeable {
this.entryFilterProvider = new EntryFilterProvider(pulsar.getConfiguration());
pulsar.getLocalMetadataStore().registerListener(this::handleMetadataChanges);
- pulsar.getConfigurationMetadataStore().registerListener(this::handleMetadataChanges);
+ if (pulsar.getConfigurationMetadataStore() != pulsar.getLocalMetadataStore()) {
+ pulsar.getConfigurationMetadataStore().registerListener(this::handleMetadataChanges);
+ }
this.inactivityMonitor = OrderedScheduler.newSchedulerBuilder()