fix

zhangqian

2023-10-20 509f1f0c121189fe3f441efca0bd2b062febd586

 pkg/nsqclient/consumer.go

@@ -92,6 +92,7 @@
      case <-n.ctx.Done():
         logx.Infof("[%s]%s stop consumer...", n.topic, n.channel)
         n.consumer.Stop()
         <-n.consumer.StopChan
         logx.Infof("[%s]%s stop consumer success", n.topic, n.channel)
         return nil
      }