diff --git a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java index 7313325..7f90c9f 100644 --- a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java +++ b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java @@ -149,10 +149,12 @@ private void doWatch(Listener2 listener) { private void notifyListener(Listener2 listener, InstancesResponse response) { ServiceInstances serviceInstances = response.toServiceInstances(); - List equivalentAddressGroups = serviceInstances.getInstances() - .stream() - .map(this::buildEquivalentAddressGroup) - .collect(Collectors.toList()); + List equivalentAddressGroups = new ArrayList<>(); + for (Instance instance : serviceInstances.getInstances()) { + if (Objects.equals("grpc", instance.getProtocol())) { + equivalentAddressGroups.add(buildEquivalentAddressGroup(instance)); + } + } Attributes.Builder builder = Attributes.newBuilder();