From 1e6e8ebf233c2bd977e2d3156ec3c01567b7150b Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 10 May 2023 15:17:07 +0800 Subject: [PATCH] zk --- internal/msgtransfer/init.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index cfac23b00..8bcb1787e 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -45,7 +45,7 @@ func StartTransfer(prometheusPort int) error { } client, err := openKeeper.NewClient(config.Config.Zookeeper.ZkAddr, config.Config.Zookeeper.Schema, openKeeper.WithFreq(time.Hour), openKeeper.WithRoundRobin(), openKeeper.WithUserNameAndPassword(config.Config.Zookeeper.UserName, - config.Config.Zookeeper.Password), openKeeper.WithRoundRobin(), openKeeper.WithTimeout(10), openKeeper.WithOptions(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())), + config.Config.Zookeeper.Password), openKeeper.WithTimeout(10), openKeeper.WithOptions(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())), ) if err != nil { return err