Elatsi c кеш - redis - не удается подключиться после записи ~ 30-40 K ключей - проблема пула подключений

Question

Я использую Elasti c redis кеша с 4 осколками и 2 узлами реплики для каждого осколка, всего 12 узлов. Я использую весенние данные redis с салатом. Ниже моя конфигурация для подключения к кластеру -

publi c LettuceConnectionFactory redisConnectionFactory () {

    List<String>  nodes = new ArrayList<>();

    nodes.add("shard1***");
    nodes.add("shard2***");
    nodes.add("shard3***");
    nodes.add("shard4***");
    RedisClusterConfiguration clusterConfiguration = new RedisClusterConfiguration(nodes);
    return new LettuceConnectionFactory(clusterConfiguration);

}

Я записываю данные в конвейер, который выполняет 5 написать команды в конвейере. Пропускная способность очень высокая для этого ~ 300K / per se c, и из-за этого я получаю ошибку ниже. Есть ли способ, которым я могу оптимизировать пул салата для решения этой проблемы. Любой указатель будет полезен.

в io.lettuce.core.LettuceFutures.awaitAll (LettuceFutures. java: 88) Причина: io.lettuce.core.RedisException: io.lettuce.core.RedisConnectionException: Невозможно подключиться к 172.26.25.141:6379

at org.springframework.data.redis.connection.lettuce.LettuceConnection.closePipeline(LettuceConnection.java:542)
... 35 more

Причина: io.lettuce.core.RedisConnectionException: Невозможно подключиться к 172.26.25.141:6379 Причина: io.lettuce.core.RedisConnectionException: невозможно подключиться к 172.26.25.141:6379

at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
at io.lettuce.core.cluster.PooledClusterConnectionProvider.lambda$getConnectionAsync$6(PooledClusterConnectionProvider.java:384)
at java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:930)
at java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:907)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync0$4(AbstractRedisClient.java:329)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)