diff --git a/pkg/common/chatrpcstart/start.go b/pkg/common/chatrpcstart/start.go index 882487da5..a89da7c51 100644 --- a/pkg/common/chatrpcstart/start.go +++ b/pkg/common/chatrpcstart/start.go @@ -42,7 +42,7 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c if err != nil { return errs.Wrap(err) } - defer zkClient.CloseZK() + //defer zkClient.CloseZK() zkClient.AddOption(chatMw.AddUserType(), mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())) registerIP, err := network.GetRpcRegisterIP(config.Config.Rpc.RegisterIP) if err != nil { diff --git a/pkg/common/config/parse.go b/pkg/common/config/parse.go index a5f38e341..4e929d61e 100644 --- a/pkg/common/config/parse.go +++ b/pkg/common/config/parse.go @@ -72,7 +72,7 @@ func InitConfig(configFile string) error { if err != nil { return utils.Wrap(err, "conn zk error ") } - defer zk.CloseZK() + //defer zk.CloseZK() var openIMConfigData []byte for i := 0; i < 100; i++ { var err error