Revert similar change in PersistentDispatcherMultipleConsumersClassic

apache · Jan 16, 2025 · cd14e7b · cd14e7b
1 parent d09c066
commit cd14e7b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java b/...apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java
@@ -600,9 +600,8 @@ public synchronized CompletableFuture<Void> disconnectAllConsumers(
 
     @Override
     protected void cancelPendingRead() {
-        if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) {
+        if (havePendingRead && cursor.cancelPendingReadRequest()) {
             havePendingRead = false;
-            havePendingReplayRead = false;
         }
     }