fix the race of delete subscription and delete topic (apache#12240)

eolivelli · Nov 29, 2021 · 1545247 · 1545247
1 parent 3b33a1e
commit 1545247
Showing 1 changed file with 5 additions 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
@@ -1023,6 +1023,11 @@ public void deleteCursorFailed(ManagedLedgerException exception, Object ctx) {
                     log.debug("[{}][{}] Error deleting cursor for subscription",
                             topic, subscriptionName, exception);
                 }
+                if (exception instanceof ManagedLedgerException.ManagedLedgerNotFoundException) {
+                    unsubscribeFuture.complete(null);
+                    lastActive = System.nanoTime();
+                    return;
+                }
                 unsubscribeFuture.completeExceptionally(new PersistenceException(exception));
             }
         }, null);