diff --git a/resolver-dns/src/main/java/io/netty/resolver/dns/DefaultDnsServerAddressStreamProvider.java b/resolver-dns/src/main/java/io/netty/resolver/dns/DefaultDnsServerAddressStreamProvider.java index b7c5bd719f..8c45f7e71e 100644 --- a/resolver-dns/src/main/java/io/netty/resolver/dns/DefaultDnsServerAddressStreamProvider.java +++ b/resolver-dns/src/main/java/io/netty/resolver/dns/DefaultDnsServerAddressStreamProvider.java @@ -69,7 +69,9 @@ public final class DefaultDnsServerAddressStreamProvider implements DnsServerAdd String[] servers = dnsUrls.split(" "); for (String server : servers) { try { - defaultNameServers.add(SocketUtils.socketAddress(new URI(server).getHost(), DNS_PORT)); + URI uri = new URI(server); + int port = uri.getPort(); + defaultNameServers.add(SocketUtils.socketAddress(uri.getHost(), port == -1 ? DNS_PORT : port)); } catch (URISyntaxException e) { logger.debug("Skipping a malformed nameserver URI: {}", server, e); }