From af31d455ed51811951df1cba9113a626e0f2c6dc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=BE=84=E6=BD=AD?= <zty98751@alibaba-inc.com>
Date: Fri, 24 Mar 2023 16:00:41 +0800
Subject: [PATCH] fix zk registry (#253)

---
 registry/zookeeper/watcher.go | 21 ---------------------
 1 file changed, 21 deletions(-)

diff --git a/registry/zookeeper/watcher.go b/registry/zookeeper/watcher.go
index f2aa96017..60a59d94b 100644
--- a/registry/zookeeper/watcher.go
+++ b/registry/zookeeper/watcher.go
@@ -103,27 +103,6 @@ func NewWatcher(cache memory.Cache, opts ...WatcherOption) (provider.Watcher, er
 		log.Info("connect zk error")
 		return nil, errors.New("connect zk error")
 	}
-	connectEvent := make(chan zk.Event, 2)
-	newClient.RegisterEvent("", connectEvent)
-	connectTimer := time.NewTimer(timeout)
-	connectTimout := false
-FOR:
-	for {
-		select {
-		case ev := <-connectEvent:
-			if ev.State == zk.StateConnected {
-				break FOR
-			}
-		case <-connectTimer.C:
-			connectTimout = true
-			break FOR
-		}
-	}
-	if connectTimout {
-		return nil, errors.New("connect zk timeout")
-	}
-	log.Info("zk connected")
-	newClient.UnregisterEvent("", connectEvent)
 	w.reconnectCh = newClient.Reconnect()
 	w.zkClient = newClient
 	go func() {