(pulsar) branch master updated: [improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore (#22519)

[technoboy]

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

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 1dd82a0affd [improve][broker] Repeat the handleMetadataChanges 
callback when configurationMetadataStore equals localMetadataStore (#22519)
1dd82a0affd is described below

commit 1dd82a0affd6ec3686fa85d444c35bbbb4e9ce12
Author: hanmz <gunn...@tencent.com>
AuthorDate: Wed Apr 17 18:14:38 2024 +0800

    [improve][broker] Repeat the handleMetadataChanges callback when 
configurationMetadataStore equals localMetadataStore (#22519)
---
 .../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 2687532693a..249008bad91 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
@@ -357,7 +357,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()
                 .name("pulsar-inactivity-monitor")