From e9585598132cf3f6fc90e195cdd7e1ba48b8df0a Mon Sep 17 00:00:00 2001 From: "R.I.Pienaar" Date: Mon, 23 Sep 2024 15:00:41 +0200 Subject: [PATCH] Log only durable orphaned consumers But log the rest at debug for dev purposes Signed-off-by: R.I.Pienaar --- server/jetstream_cluster.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 06c3c11ca72..cc301e9bf84 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -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) }