From bf9ac2a391b49d49580de5e8929ab59ac794dc15 Mon Sep 17 00:00:00 2001 From: gabsferrara Date: Wed, 19 Jun 2024 12:05:48 -0300 Subject: [PATCH] change log level when consumer channel is closed --- pkg/stream/server_frame.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/stream/server_frame.go b/pkg/stream/server_frame.go index ff19ff08..e69cb24d 100644 --- a/pkg/stream/server_frame.go +++ b/pkg/stream/server_frame.go @@ -415,7 +415,7 @@ func (c *Client) handleDeliver(r *bufio.Reader) { if consumer.getStatus() == open { consumer.response.chunkForConsumer <- chunk } else { - logs.LogWarn("Consumer %s is closed", consumer.GetStreamName()) + logs.LogDebug("Consumer %s is closed", consumer.GetStreamName()) } }