Skip to content

Commit

Permalink
Log only durable orphaned consumers
Browse files Browse the repository at this point in the history
But log the rest at debug for dev purposes

Signed-off-by: R.I.Pienaar <rip@devco.net>
  • Loading branch information
ripienaar authored and neilalexander committed Sep 24, 2024
1 parent ccc51ae commit e958559
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion server/jetstream_cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -1200,7 +1200,12 @@ func (js *jetStream) checkForOrphans() {
stream = mset.cfg.Name
mset.mu.RUnlock()
}
s.Warnf("Detected orphaned consumer '%s > %s > %s', will cleanup", accName, stream, consumer)
if o.isDurable() {
s.Warnf("Detected orphaned durable consumer '%s > %s > %s', will cleanup", accName, stream, consumer)
} else {
s.Debugf("Detected orphaned consumer '%s > %s > %s', will cleanup", accName, stream, consumer)
}

if err := o.delete(); err != nil {
s.Warnf("Deleting consumer encountered an error: %v", err)
}
Expand Down

0 comments on commit e958559

Please sign in to comment.