You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2024/08/13 03:10:17 UTC
(pulsar) branch branch-3.0 updated: [fix][broker] Fix 'Disabled replicated subscriptions controller' logic and logging (#23142)
This is an automated email from the ASF dual-hosted git repository.
zixuan 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 4235a53241c [fix][broker] Fix 'Disabled replicated subscriptions controller' logic and logging (#23142)
4235a53241c is described below
commit 4235a53241c359c10826e98327814f04335c35cc
Author: hanmz <gu...@tencent.com>
AuthorDate: Tue Aug 13 11:06:01 2024 +0800
[fix][broker] Fix 'Disabled replicated subscriptions controller' logic and logging (#23142)
(cherry picked from commit 9bf714ff756b0729094e9a8611137d3dcfaed5b0)
---
.../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 8c84b801428..f23d0c2d0f2 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
@@ -3755,8 +3755,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();