[fix][broker] replicator leak when removeReplicator in NonPersistentT…

…opic (#21205)
apache · Sep 25, 2023 · b877344 · b877344
1 parent 786f892
commit b877344
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...oker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java b/...oker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
@@ -607,6 +607,7 @@ CompletableFuture<Void> removeReplicator(String remoteCluster) {
 
         replicators.get(remoteCluster).disconnect().thenRun(() -> {
             log.info("[{}] Successfully removed replicator {}", name, remoteCluster);
+            replicators.remove(remoteCluster);
 
         }).exceptionally(e -> {
             log.error("[{}] Failed to close replication producer {} {}", topic, name, e.getMessage(), e);