From a77884e4ec00e4f75a6a9e924f62273759f7b9ca Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 13 Apr 2023 18:20:13 -0700 Subject: [PATCH] Do not let the redelivered count go down on re-applying on restarts Signed-off-by: Derek Collison --- server/filestore.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/filestore.go b/server/filestore.go index 70d9eef8..caf0b945 100644 --- a/server/filestore.go +++ b/server/filestore.go @@ -6687,7 +6687,10 @@ func (o *consumerFileStore) UpdateDelivered(dseq, sseq, dc uint64, ts int64) err if o.state.Redelivered == nil { o.state.Redelivered = make(map[uint64]uint64) } - o.state.Redelivered[sseq] = dc - 1 + // Only update if greater then what we already have. + if o.state.Redelivered[sseq] < dc { + o.state.Redelivered[sseq] = dc - 1 + } } } else { // For AckNone just update delivered and ackfloor at the same time.