Skip to content

Commit

Permalink
Do jump consumer ack floor but not stream
Browse files Browse the repository at this point in the history
Signed-off-by: Derek Collison <derek@nats.io>
  • Loading branch information
derekcollison authored and wallyqs committed Apr 27, 2024
1 parent 7ad697f commit ed64b8b
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions server/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -2739,6 +2739,11 @@ func (o *consumer) processAckMsg(sseq, dseq, dc uint64, doSample bool) {
}
}
}
// If nothing left set consumer to current delivered.
// Do not update stream.
if len(o.pending) == 0 {
o.adflr = o.dseq - 1
}
}
// We do these regardless.
delete(o.rdc, sseq)
Expand Down

0 comments on commit ed64b8b

Please sign in to comment.