diff --git a/registry/consul/registry.go b/registry/consul/registry.go
index 0fd555429f5dcb48b03f53a896a529f01d4b1ca5..1fd3e54e96c446f59dd31ab30575eef5b455b72f 100644
--- a/registry/consul/registry.go
+++ b/registry/consul/registry.go
@@ -150,7 +150,6 @@ func (r *consulRegistry) Subscribe(url *common.URL, notifyListener registry.Noti
 			if serviceEvent, err := listener.Next(); err != nil {
 				logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
 				listener.Close()
-				time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
 				return
 			} else {
 				logger.Infof("update begin, service event: %v", serviceEvent.String())
diff --git a/registry/etcdv3/registry.go b/registry/etcdv3/registry.go
index 00231ad8009caa3c33b256e939c71ce31873dd9d..ca02d1f2ef2854e50bb62f1f7c193922852e04d8 100644
--- a/registry/etcdv3/registry.go
+++ b/registry/etcdv3/registry.go
@@ -352,7 +352,6 @@ func (r *etcdV3Registry) Subscribe(url *common.URL, notifyListener registry.Noti
 			if serviceEvent, err := listener.Next(); err != nil {
 				logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
 				listener.Close()
-				time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
 				return
 			} else {
 				logger.Infof("update begin, service event: %v", serviceEvent.String())
diff --git a/registry/nacos/registry.go b/registry/nacos/registry.go
index 52980006e109a8843a33a33ef484642d6680b33f..3699fab3c561bd8831b35462dc4a92ec27df94db 100644
--- a/registry/nacos/registry.go
+++ b/registry/nacos/registry.go
@@ -192,7 +192,6 @@ func (r *nacosRegistry) Subscribe(url *common.URL, notifyListener registry.Notif
 			if serviceEvent, err := listener.Next(); err != nil {
 				logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
 				listener.Close()
-				time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
 				return
 			} else {
 				logger.Infof("update begin, service event: %v", serviceEvent.String())
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
index ba58848829725cd7af0897e57efd841aa4ec8fa5..6f892b8f4be1da4ce9c84a692e79be5036f789ca 100644
--- a/registry/zookeeper/registry.go
+++ b/registry/zookeeper/registry.go
@@ -420,7 +420,6 @@ func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyLi
 			if serviceEvent, err := listener.Next(); err != nil {
 				logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
 				listener.Close()
-				time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
 				return
 			} else {
 				logger.Infof("update begin, service event: %v", serviceEvent.String())