This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b940c0f78542a5ed64eb325d89d5c626cd02a832 Author: Lari Hotari <[email protected]> AuthorDate: Tue Oct 1 22:54:32 2024 +0300 [fix][broker] Cancel possible pending replay read in cancelPendingRead (#23384) (cherry picked from commit d2c91b1e1a8fc2fb233eb2856ddb6f53511ba201) --- .../service/persistent/PersistentDispatcherMultipleConsumers.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java index ae844b57844..9e8483be1a7 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java @@ -553,8 +553,9 @@ public class PersistentDispatcherMultipleConsumers extends AbstractDispatcherMul @Override protected void cancelPendingRead() { - if (havePendingRead && cursor.cancelPendingReadRequest()) { + if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) { havePendingRead = false; + havePendingReplayRead = false; } }
