Skip to content

Commit

Permalink
[fix][broker] Cancel possible pending replay read in cancelPendingRead (
Browse files Browse the repository at this point in the history
apache#23384)

(cherry picked from commit d2c91b1)
  • Loading branch information
lhotari committed Oct 4, 2024
1 parent 988b884 commit b940c0f
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -553,8 +553,9 @@ public synchronized CompletableFuture<Void> disconnectAllConsumers(boolean isRes

@Override
protected void cancelPendingRead() {
if (havePendingRead && cursor.cancelPendingReadRequest()) {
if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) {
havePendingRead = false;
havePendingReplayRead = false;
}
}

Expand Down

0 comments on commit b940c0f

Please # to comment.