mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
Merge branch 'main' into dev
This commit is contained in:
@@ -4005,7 +4005,7 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) {
|
||||
}
|
||||
|
||||
// Check several things to see if we need a snapshot.
|
||||
if !force && !n.NeedSnapshot() {
|
||||
if !force || !n.NeedSnapshot() {
|
||||
// Check if we should compact etc. based on size of log.
|
||||
if ne, nb := n.Size(); ne < compactNumMin && nb < compactSizeMin {
|
||||
return
|
||||
|
||||
Reference in New Issue
Block a user