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) {