From b0c3cf0dbd475ef11cef94832cf8f613d6149f8f Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Mon, 3 Apr 2023 17:22:50 -0700 Subject: [PATCH] Only apply consumer entries if not recovering Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 5a16ed116c..7e8bf75d26 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -4293,16 +4293,16 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) { } // Check our state if we are under an interest based stream. o.checkStateForInterestStream() - continue - } - if err := js.applyConsumerEntries(o, ce, isLeader); err == nil { - ne, nb := n.Applied(ce.Index) - // If we have at least min entries to compact, go ahead and snapshot/compact. - if nb > 0 && ne >= compactNumMin || nb > compactSizeMin { - doSnapshot(false) + } else if !recovering { + if err := js.applyConsumerEntries(o, ce, isLeader); err == nil { + ne, nb := n.Applied(ce.Index) + // If we have at least min entries to compact, go ahead and snapshot/compact. + if nb > 0 && ne >= compactNumMin || nb > compactSizeMin { + doSnapshot(false) + } + } else { + s.Warnf("Error applying consumer entries to '%s > %s'", ca.Client.serviceAccount(), ca.Name) } - } else { - s.Warnf("Error applying consumer entries to '%s > %s'", ca.Client.serviceAccount(), ca.Name) } } aq.recycle(&ces)