Skip to content

Commit b47ca39

Browse files
lhotarihanmz
authored andcommitted
[fix][broker] Cancel possible pending replay read in cancelPendingRead (apache#23384)
1 parent edd980e commit b47ca39

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -650,8 +650,9 @@ public synchronized CompletableFuture<Void> disconnectAllConsumers(
650650

651651
@Override
652652
protected void cancelPendingRead() {
653-
if (havePendingRead && cursor.cancelPendingReadRequest()) {
653+
if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) {
654654
havePendingRead = false;
655+
havePendingReplayRead = false;
655656
}
656657
}
657658

0 commit comments

Comments
 (0)