zk

2026-05-10 12:05:58 +08:00 · 2023-05-10 11:52:12 +08:00
parent 5c50be3c50
commit 143def1b0d
3 changed files with 4 additions and 2 deletions
@@ -34,7 +34,7 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c
 	if err != nil {
 		return utils.Wrap1(err)
 	}
-	defer zkClient.Close()
+	defer zkClient.CloseZK()
 	zkClient.AddOption(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials()))
 	registerIP, err := network.GetRpcRegisterIP(config.Config.RpcRegisterIP)
 	if err != nil {