[fix][broker] Cancel possible pending replay read in cancelPendingRead (

#23384)
apache · Oct 1, 2024 · d2c91b1 · d2c91b1
1 parent 9eeffe5
commit d2c91b1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -650,8 +650,9 @@ public synchronized CompletableFuture<Void> disconnectAllConsumers(
 
     @Override
     protected void cancelPendingRead() {
-        if (havePendingRead && cursor.cancelPendingReadRequest()) {
+        if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) {
             havePendingRead = false;
+            havePendingReplayRead = false;
         }
     }