From ead25c24eca4758a04e2bba389a8c6af63d698d5 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 10 May 2023 16:32:44 +0800 Subject: [PATCH] zk --- internal/msgtransfer/init.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 8bcb1787e..4249a429b 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -45,11 +45,12 @@ 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.WithTimeout(10), openKeeper.WithOptions(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())), - ) + config.Config.Zookeeper.Password), openKeeper.WithTimeout(10)) + if err != nil { return err } + client.AddOption(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())) msgModel := cache.NewMsgCacheModel(rdb) notificationModel := cache.NewNotificationCacheModel(rdb) msgDocModel := unrelation.NewMsgMongoDriver(mongo.GetDatabase())