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()) } }