diff --git a/pkg/discoveryregistry/zookeeper/resolver.go b/pkg/discoveryregistry/zookeeper/resolver.go index ff0e7b32c..cf214e714 100644 --- a/pkg/discoveryregistry/zookeeper/resolver.go +++ b/pkg/discoveryregistry/zookeeper/resolver.go @@ -46,8 +46,9 @@ func (s *ZkClient) Build(target resolver.Target, cc resolver.ClientConn, opts re r.ResolveNowZK(resolver.ResolveNowOptions{}) s.lock.Lock() defer s.lock.Unlock() - s.resolvers[strings.TrimLeft(target.URL.Path, "/")] = r - s.logger.Printf("build resolver finished: %+v, cc: %+v, key: ", target, cc, strings.TrimLeft(target.URL.Path, "/")) + serviceName := strings.TrimLeft(target.URL.Path, "/") + s.resolvers[serviceName] = r + s.logger.Printf("build resolver finished: %+v, cc: %+v, key: ", target, cc, serviceName) return r, nil } diff --git a/pkg/discoveryregistry/zookeeper/zk.go b/pkg/discoveryregistry/zookeeper/zk.go index 2b47c9f77..be0fb5bb0 100644 --- a/pkg/discoveryregistry/zookeeper/zk.go +++ b/pkg/discoveryregistry/zookeeper/zk.go @@ -162,7 +162,6 @@ func (s *ZkClient) flushResolver(serviceName string) { r, ok := s.resolvers[serviceName] if ok { r.ResolveNowZK(resolver.ResolveNowOptions{}) - s.resolvers[serviceName] = r } }