diff --git a/redisson/src/main/java/org/redisson/connection/SequentialDnsAddressResolverFactory.java b/redisson/src/main/java/org/redisson/connection/SequentialDnsAddressResolverFactory.java index 5fec788b6..a31087cf6 100644 --- a/redisson/src/main/java/org/redisson/connection/SequentialDnsAddressResolverFactory.java +++ b/redisson/src/main/java/org/redisson/connection/SequentialDnsAddressResolverFactory.java @@ -21,8 +21,7 @@ import io.netty.resolver.AddressResolver; import io.netty.resolver.AddressResolverGroup; import io.netty.resolver.InetSocketAddressResolver; import io.netty.resolver.NameResolver; -import io.netty.resolver.dns.DnsAddressResolverGroup; -import io.netty.resolver.dns.DnsServerAddressStreamProvider; +import io.netty.resolver.dns.*; import io.netty.util.concurrent.EventExecutor; import io.netty.util.concurrent.Promise; import org.redisson.misc.AsyncSemaphore; @@ -91,7 +90,13 @@ public class SequentialDnsAddressResolverFactory implements AddressResolverGroup @Override public AddressResolverGroup create(Class channelType, DnsServerAddressStreamProvider nameServerProvider) { - DnsAddressResolverGroup group = new DnsAddressResolverGroup(channelType, nameServerProvider) { + DnsNameResolverBuilder dnsResolverBuilder = new DnsNameResolverBuilder(); + dnsResolverBuilder.channelType(channelType) + .nameServerProvider(nameServerProvider) + .resolveCache(new DefaultDnsCache(0, Integer.MAX_VALUE, 0)) + .cnameCache(new DefaultDnsCnameCache(0, Integer.MAX_VALUE)); + + DnsAddressResolverGroup group = new DnsAddressResolverGroup(dnsResolverBuilder) { @Override protected AddressResolver newAddressResolver(EventLoop eventLoop, NameResolver resolver) throws Exception { return new LimitedInetSocketAddressResolver(asyncSemaphore, eventLoop, resolver);