pkg/nsqclient/consumer.go
@@ -90,9 +90,9 @@ for { select { case <-n.ctx.Done(): logx.Infof("[%s] %s", "stop consumer...", n.topic, n.channel) logx.Infof("[%s]%s stop consumer...", n.topic, n.channel) n.consumer.Stop() logx.Infof("[%s] %s", "stop consumer success", n.topic, n.channel) logx.Infof("[%s]%s stop consumer success", n.topic, n.channel) return nil } }