Fix multiple dial on add consumer

2024-05-03 14:30:05 +03:00
parent b3c5ef8c86
commit 2ea66deb08
3 changed files with 38 additions and 26 deletions
@@ -245,10 +245,10 @@ func (p *Producer) stop() {

 	switch p.state {
 	case stateExternal:
-		log.Debug().Msgf("[streams] can't stop external producer")
+		log.Trace().Msgf("[streams] skip stop external producer")
 		return
 	case stateNone:
-		log.Debug().Msgf("[streams] can't stop none producer")
+		log.Trace().Msgf("[streams] skip stop none producer")
 		return
 	case stateStart:
 		p.workerID++