Skip to content

Commit 018eb3f

Browse files
hanmznodece
authored andcommitted
[fix][broker] Fix 'Disabled replicated subscriptions controller' logic and logging (#23142)
(cherry picked from commit 9bf714f)
1 parent 54966c9 commit 018eb3f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -2933,8 +2933,8 @@ private synchronized void checkReplicatedSubscriptionControllerState(boolean sho
29332933
log.info("[{}] Enabling replicated subscriptions controller", topic);
29342934
replicatedSubscriptionsController = Optional.of(new ReplicatedSubscriptionsController(this,
29352935
brokerService.pulsar().getConfiguration().getClusterName()));
2936-
} else if (isCurrentlyEnabled && !shouldBeEnabled || !isEnableReplicatedSubscriptions
2937-
|| !replicationEnabled) {
2936+
} else if (isCurrentlyEnabled && (!shouldBeEnabled || !isEnableReplicatedSubscriptions
2937+
|| !replicationEnabled)) {
29382938
log.info("[{}] Disabled replicated subscriptions controller", topic);
29392939
replicatedSubscriptionsController.ifPresent(ReplicatedSubscriptionsController::close);
29402940
replicatedSubscriptionsController = Optional.empty();

0 commit comments

Comments
 (0)