From fed4dbd54fe13da2ba638fdf7b8ed53814558cc5 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Mon, 13 Mar 2023 13:31:40 +0800 Subject: [PATCH] zk add client options --- internal/startrpc/start.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/startrpc/start.go b/internal/startrpc/start.go index d47734b9c..f40944735 100644 --- a/internal/startrpc/start.go +++ b/internal/startrpc/start.go @@ -31,7 +31,7 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c return utils.Wrap1(err) } defer zkClient.Close() - zkClient.AddOption(grpc.WithTransportCredentials(insecure.NewCredentials())) + zkClient.AddOption(grpc.WithTransportCredentials(insecure.NewCredentials()), mw.GrpcClient()) registerIP, err := network.GetRpcRegisterIP(config.Config.RpcRegisterIP) if err != nil { return err