[pulsar] branch branch-2.8 updated: [pulsar-broker] Add stop replicator producer logic when start replicator cluster failed. (#12724)

[penghui]

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

penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.8 by this push:
     new fc7cba4  [pulsar-broker] Add stop replicator producer logic when start 
replicator cluster failed. (#12724)
fc7cba4 is described below

commit fc7cba40160eb85d6d465c10d5981bd26b95fc45
Author: Jiwei Guo <techno...@apache.org>
AuthorDate: Thu Nov 11 23:38:09 2021 +0800

    [pulsar-broker] Add stop replicator producer logic when start replicator 
cluster failed. (#12724)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java     | 1 +
 1 file changed, 1 insertion(+)

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 22df2df..cdc0e00 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
@@ -280,6 +280,7 @@ public class PersistentTopic extends AbstractTopic
                     log.warn("[{}] failed to start replication", topic, e);
                 }
                 if (!isReplicatorStarted) {
+                    stopReplProducers();
                     throw new NamingException(
                             PersistentTopic.this.getName() + " Failed to start 
replicator " + remoteCluster);
                 }