From 64c40116a6bae5ad59cde00a2bd3b4ce32c1fde1 Mon Sep 17 00:00:00 2001
From: penghui <penghui@apache.org>
Date: Wed, 14 Sep 2022 22:22:25 +0800
Subject: [PATCH] [fix][broker] Unregister topic policy listener if managed
 ledger close failed

---
 .../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 4d48f9c627e76..52bb165a61e91 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
@@ -1323,6 +1323,7 @@ public void closeComplete(Object ctx) {
                 public void closeFailed(ManagedLedgerException exception, Object ctx) {
                     log.error("[{}] Failed to close managed ledger, proceeding anyway.", topic, exception);
                     brokerService.removeTopicFromCache(topic);
+                    unregisterTopicPolicyListener();
                     closeFuture.complete(null);
                 }
             }, null);