From b34cf4d9119b8567f94a706ccd7c96872344bb33 Mon Sep 17 00:00:00 2001 From: Maurice van Veen Date: Fri, 11 Apr 2025 11:03:26 +0200 Subject: [PATCH] [FIXED] AckAll R1 consumer use correct floor Signed-off-by: Maurice van Veen --- server/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/consumer.go b/server/consumer.go index f8efd551ce6..a441663bf8e 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -3159,7 +3159,7 @@ func (o *consumer) processAckMsg(sseq, dseq, dc uint64, reply string, doSample b needSignal = true } sgap = sseq - o.asflr - floor = sgap // start at same and set lower as we go. + floor = sseq // start at same and set lower as we go. o.adflr, o.asflr = dseq, sseq remove := func(seq uint64) {