diff --git a/pkg/discoveryregistry/zookeeper/discover.go b/pkg/discoveryregistry/zookeeper/discover.go index 4404be4cf..07a2bce17 100644 --- a/pkg/discoveryregistry/zookeeper/discover.go +++ b/pkg/discoveryregistry/zookeeper/discover.go @@ -6,6 +6,7 @@ import ( "strings" "sync" + "github.com/OpenIMSDK/Open-IM-Server/pkg/common/log" "github.com/pkg/errors" "github.com/go-zookeeper/zk" @@ -24,6 +25,7 @@ func (s *ZkClient) watch(wg *sync.WaitGroup) { case zk.EventSession: case zk.EventNodeCreated: case zk.EventNodeChildrenChanged: + log.ZDebug(context.Background(), "zk event", "event", event.Path) l := strings.Split(event.Path, "/") s.lock.Lock() if len(l) > 1 { diff --git a/pkg/discoveryregistry/zookeeper/resolver.go b/pkg/discoveryregistry/zookeeper/resolver.go index 926681ba5..876060e73 100644 --- a/pkg/discoveryregistry/zookeeper/resolver.go +++ b/pkg/discoveryregistry/zookeeper/resolver.go @@ -25,7 +25,7 @@ func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions) { } r.addrs = newConns log.ZDebug(context.Background(), "resolve now finished", "target", r.target, "conns", r.addrs) - r.cc.UpdateState(resolver.State{Addresses: r.addrs}) + r.cc.UpdateState(resolver.State{Addresses: newConns}) } func (s *Resolver) Close() {}