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

…opic (apache#21205)
ascentstream · Sep 21, 2023 · 66271e3 · 66271e3
1 parent e5b0f17
commit 66271e3
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
@@ -634,6 +634,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);