diff --git a/registry/nacos/v2/watcher.go b/registry/nacos/v2/watcher.go index 2e89ea507..24be217cd 100644 --- a/registry/nacos/v2/watcher.go +++ b/registry/nacos/v2/watcher.go @@ -317,7 +317,7 @@ func (w *watcher) fetchAllServices() error { for _, serviceName := range ss.Doms { fetchedServices[groupName+DefaultJoiner+serviceName] = true } - if ss.Count < DefaultFetchPageSize { + if len(ss.Doms) < DefaultFetchPageSize { break } } diff --git a/registry/nacos/watcher.go b/registry/nacos/watcher.go index 48b508c8e..fdd075cf0 100644 --- a/registry/nacos/watcher.go +++ b/registry/nacos/watcher.go @@ -238,7 +238,7 @@ func (w *watcher) fetchAllServices() error { for _, serviceName := range ss.Doms { fetchedServices[groupName+DefaultJoiner+serviceName] = true } - if ss.Count < DefaultFetchPageSize { + if len(ss.Doms) < DefaultFetchPageSize { break } }