diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java index 73b204f474944..285710e29305a 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java @@ -974,6 +974,7 @@ public synchronized void asyncDeleteCursor(final String consumerName, final Dele return; } else if (!cursor.isDurable()) { cursors.removeCursor(consumerName); + cursor.setInactive(); callback.deleteCursorComplete(ctx); return; } @@ -984,6 +985,7 @@ public synchronized void asyncDeleteCursor(final String consumerName, final Dele @Override public void operationComplete(Void result, Stat stat) { cursor.asyncDeleteCursorLedger(); + cursor.setInactive(); cursors.removeCursor(consumerName); // Redo invalidation of entries in cache