fix[connector]: prevent flag reconnectUsesNewConnection in cluster sc…

…enarios
camunda-community-hub · Feb 15, 2024 · 3b34f51 · 3b34f51
1 parent 88402fb
commit 3b34f51
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/connector-java/src/main/java/io/zeebe/redis/connect/java/ZeebeRedis.java b/connector-java/src/main/java/io/zeebe/redis/connect/java/ZeebeRedis.java
@@ -141,7 +141,9 @@ protected void start() {
         redisConnection.close();
       }
       if (reconnectUsesNewConnection) {
+        // take care to not close the whole connection pool in case of failing cluster connections
         LOGGER.warn("Parameter 'reconnectUsesNewConnection' has no effect when using RedisClusterClient.");
+        reconnectUsesNewConnection = false;
       }
     } else {
       // if we're not connected to a cluster we eventually handle reconnects ourselves