Redis Cluster connection via lettuce client

[akshagr]

Hi @mp911de,

I am trying to connect to AWS EC Clustered Redis v6.x using lettuce client v5.1.5.RELEASE. I am getting "Connection refused " exception. Here I am attaching the code snippet and the logs. Please look into it.
Code -
`RedisURI redisURI =
RedisURI.Builder.redis(shard.host, shard.port)
.withDatabase(0)
.build();
redisURIs.add(redisURI);

RedisClusterClient redisClient = RedisClusterClient.create(redisURIs);
redisClient.setOptions(
    ClusterClientOptions.builder()
        .pingBeforeActivateConnection(true)
        .autoReconnect(true)
        .socketOptions(
            SocketOptions.builder().connectTimeout(20000, TimeUnit.MILLISECONDS).build())
        .topologyRefreshOptions(
            ClusterTopologyRefreshOptions.builder()
                .enableAllAdaptiveRefreshTriggers()
                .refreshPeriod(Duration.ofSeconds(5))
                .build())
        .build());

StatefulRedisClusterConnection<String, String> connection =
    redisClient.connect(StringCodec.UTF8);
connection.setReadFrom(ReadFrom.SLAVE_PREFERRED);

GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxIdle(maxIdle);
poolConfig.setMaxIdle(minIdle);
poolConfig.setMaxTotal(maxTotal);
poolConfig.setBlockWhenExhausted(true);
GenericObjectPool<StatefulRedisClusterConnection<String, String>> pool =
    ConnectionPoolSupport.createGenericObjectPool(() -> connection, poolConfig);`

Logs -
web_1 | 2021-10-24T16:21:36,809 severity=INFO class=EpollProvider Starting without optional epoll library web_1 | 2021-10-24T16:21:36,811 severity=INFO class=KqueueProvider Starting without optional kqueue library web_1 | 2021-10-24T16:21:37,102 severity=DEBUG class=CommandHandler [channel=0xdb82a82d, [id: 0xa7ef5506] (inactive), chid=0x1] channelRegistered() web_1 | 2021-10-24T16:21:52,076 severity=DEBUG class=DefaultEndpoint [unknown, epid=0x1] closeAsync() web_1 | 24-Oct-2021 16:21:52.080 SEVERE [main] org.apache.catalina.core.StandardContext.startInternal One or more listeners failed to start. Full details will be found in the appropriate container log file web_1 | 24-Oct-2021 16:21:52.088 SEVERE [main] org.apache.catalina.core.StandardContext.startInternal Context [] startup failed due to previous errors web_1 | 2021-10-24T16:21:52,078 severity=WARN class=ClusterTopologyRefresh Unable to connect to <configuration_endpoint>:6380 web_1 | java.util.concurrent.CompletionException: io.netty.channel.ConnectTimeoutException: connection timed out: auction-cluster-dev.dktrm8.clustercfg.usw2.cache.amazonaws.com/10.196.169.10:6380 web_1 | at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331) ~[?:?] web_1 | at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346) ~[?:?] web_1 | at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:632) ~[?:?] web_1 | at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?] web_1 | at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088) ~[?:?] web_1 | at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync0$4(AbstractRedisClient.java:329) ~[lettuce-core-5.1.5.RELEASE.jar:?] web_1 | at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:121) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:269) ~[netty-transport-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:127) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:495) ~[netty-transport-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:905) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.33.Final.jar:4.1.33.Final] web_1 | at java.lang.Thread.run(Thread.java:829) [?:?] web_1 | Caused by: io.netty.channel.ConnectTimeoutException: connection timed out: auction-cluster-dev.dktrm8.clustercfg.usw2.cache.amazonaws.com/10.196.169.10:6380 web_1 | at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:267) ~[netty-transport-4.1.33.Final.jar:4.1.33.Final] web_1 | ... 8 more web_1 | 2021-10-24T16:21:52,080 severity=DEBUG class=CommandHandler [channel=0xdb82a82d, [id: 0xa7ef5506] (inactive), chid=0x1] channelUnregistered()

[akshagr]

Closing ticket, it has been resolved.