diff --git a/cmd/streams/producer.go b/cmd/streams/producer.go index 7bc45905..cfe3afcd 100644 --- a/cmd/streams/producer.go +++ b/cmd/streams/producer.go @@ -112,7 +112,7 @@ func (p *Producer) reconnect() { defer p.mu.Unlock() if p.state != stateStart { - log.Debug().Msgf("[streams] closed ...") + log.Trace().Msgf("[streams] stop reconnect url=%s", p.url) return }