diff --git a/registry/kubernetes_registry.go b/registry/kubernetes_registry.go
index 4181c219..77fe0db4 100644
--- a/registry/kubernetes_registry.go
+++ b/registry/kubernetes_registry.go
@@ -38,7 +38,9 @@ func (c *KubernetesRegistry) GetService(name string) (Service, error) {
 		return service, nil
 	}
 
-	services, err := c.Client.Services(c.Namespace).List(labels.OneTermEqualSelector("name", name))
+	selector := labels.SelectorFromSet(labels.Set{"name": name})
+
+	services, err := c.Client.Services(c.Namespace).List(selector)
 	if err != nil {
 		return nil, err
 	}
@@ -51,7 +53,7 @@ func (c *KubernetesRegistry) GetService(name string) (Service, error) {
 	for _, item := range services.Items {
 		ks.ServiceNodes = append(ks.ServiceNodes, &KubernetesNode{
 			NodeAddress: item.Spec.PortalIP,
-			NodePort:    item.Spec.Port,
+			NodePort:    item.Spec.Ports[0].Port,
 		})
 	}
 
diff --git a/registry/kubernetes_watcher.go b/registry/kubernetes_watcher.go
index 2804c114..319d8132 100644
--- a/registry/kubernetes_watcher.go
+++ b/registry/kubernetes_watcher.go
@@ -32,7 +32,7 @@ func (k *KubernetesWatcher) OnUpdate(services []api.Service) {
 			ServiceNodes: []*KubernetesNode{
 				&KubernetesNode{
 					NodeAddress: serviceIP.String(),
-					NodePort:    service.Spec.Port,
+					NodePort:    service.Spec.Ports[0].Port,
 				},
 			},
 		}