(pulsar) branch master updated: [fix][broker] Fix 'Disabled replicated subscriptions controller' logic and logging (#23142)

[zixuan]

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

zixuan 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 9bf714ff756 [fix][broker] Fix 'Disabled replicated subscriptions 
controller' logic and logging (#23142)
9bf714ff756 is described below

commit 9bf714ff756b0729094e9a8611137d3dcfaed5b0
Author: hanmz <gunn...@tencent.com>
AuthorDate: Tue Aug 13 11:06:01 2024 +0800

    [fix][broker] Fix 'Disabled replicated subscriptions controller' logic and 
logging (#23142)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 7a520d879b7..e890bac620e 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -4103,8 +4103,8 @@ public class PersistentTopic extends AbstractTopic 
implements Topic, AddEntryCal
             log.info("[{}] Enabling replicated subscriptions controller", 
topic);
             replicatedSubscriptionsController = Optional.of(new 
ReplicatedSubscriptionsController(this,
                     
brokerService.pulsar().getConfiguration().getClusterName()));
-        } else if (isCurrentlyEnabled && !shouldBeEnabled || 
!isEnableReplicatedSubscriptions
-                || !replicationEnabled) {
+        } else if (isCurrentlyEnabled && (!shouldBeEnabled || 
!isEnableReplicatedSubscriptions
+                || !replicationEnabled)) {
             log.info("[{}] Disabled replicated subscriptions controller", 
topic);
             
replicatedSubscriptionsController.ifPresent(ReplicatedSubscriptionsController::close);
             replicatedSubscriptionsController = Optional.empty();