nsq/nsq.go
@@ -53,6 +53,7 @@ logx.Errorf("start nsq consume err: %v", err) } c.clients.Store(topic, client) if len(conf.Conf.NsqConf.NsqlookupdAddr) > 0 { if err = client.RunLookupd(conf.Conf.NsqConf.NsqlookupdAddr, 1); err != nil { logx.Errorf("RunLookupd err:%v", err)
