fix

zhangqian

2023-12-01 8324f872ef3a4d0c978a9b1d062800c6a1701c12

 pkg/nsqclient/consumer.go

@@ -91,9 +91,6 @@
      select {
      case <-n.ctx.Done():
         logx.Infof("[%s] stop consumer...", n.topic)
         n.consumer.Stop()
         <-n.consumer.StopChan
         logx.Infof("[%s] stop consumer success", n.topic)
         for _, addr := range qAddr {
            err = n.consumer.DisconnectFromNSQD(addr)
            if err != nil {
@@ -102,6 +99,10 @@
               logx.Infof("disconnect from nsq server success, addr: %v, topic: %v", addr, n.topic)
            }
         }
         n.consumer.Stop()
         <-n.consumer.StopChan
         logx.Infof("[%s] stop consumer success", n.topic)

         return nil
      }
   }