From a393eebe4b3fb92179838e3ccf79b9fb5a3f1f0b Mon Sep 17 00:00:00 2001 From: Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Tue, 23 Apr 2024 16:43:33 +0800 Subject: [PATCH] refactor: zk log debug. --- pkg/common/discoveryregister/discoveryregister.go | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/pkg/common/discoveryregister/discoveryregister.go b/pkg/common/discoveryregister/discoveryregister.go index 287b9dbf0..38d7382fa 100644 --- a/pkg/common/discoveryregister/discoveryregister.go +++ b/pkg/common/discoveryregister/discoveryregister.go @@ -20,8 +20,6 @@ import ( "github.com/openimsdk/tools/discovery" "github.com/openimsdk/tools/discovery/zookeeper" "github.com/openimsdk/tools/errs" - "github.com/openimsdk/tools/log" - "os" "time" ) @@ -35,10 +33,7 @@ const ( func NewDiscoveryRegister(zookeeperConfig *config.ZooKeeper, share *config.Share) (discovery.SvcDiscoveryRegistry, error) { switch share.Env { case zookeeperConst: - zklogger, err := log.NewConsoleZapLogger("", 6, false, config.Version, os.Stdout) - if err != nil { - return nil, errs.Wrap(err) - } + return zookeeper.NewZkClient( zookeeperConfig.Address, zookeeperConfig.Schema, @@ -46,7 +41,6 @@ func NewDiscoveryRegister(zookeeperConfig *config.ZooKeeper, share *config.Share zookeeper.WithUserNameAndPassword(zookeeperConfig.Username, zookeeperConfig.Password), zookeeper.WithRoundRobin(), zookeeper.WithTimeout(10), - zookeeper.WithLogger(zklogger), ) case kubenetesConst: return kubernetes.NewK8sDiscoveryRegister(share.RpcRegisterName.MessageGateway)