[pulsar-broker] Add stop replicator producer logic when start replica…

…tor cluster failed. (apache#12724)
datastax · Nov 11, 2021 · fc7cba4 · fc7cba4
1 parent a749a31
commit fc7cba4
Showing 1 changed file with 1 addition and 0 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
@@ -280,6 +280,7 @@ public PersistentTopic(String topic, ManagedLedger ledger, BrokerService brokerS
                     log.warn("[{}] failed to start replication", topic, e);
                 }
                 if (!isReplicatorStarted) {
+                    stopReplProducers();
                     throw new NamingException(
                             PersistentTopic.this.getName() + " Failed to start replicator " + remoteCluster);
                 }