DBZ-7646 allowing connection to unsecured Redis database

debezium · Mar 14, 2024 · 5aee7b3 · 5aee7b3
1 parent 71256cf
commit 5aee7b3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...orage/debezium-storage-redis/src/main/java/io/debezium/storage/redis/RedisConnection.java b/...orage/debezium-storage-redis/src/main/java/io/debezium/storage/redis/RedisConnection.java
@@ -11,7 +11,7 @@
 import org.slf4j.LoggerFactory;
 
 import io.debezium.DebeziumException;
-
+import io.debezium.util.Strings;
 import redis.clients.jedis.DefaultJedisClientConfig;
 import redis.clients.jedis.HostAndPort;
 import redis.clients.jedis.Jedis;
@@ -81,10 +81,10 @@ public RedisClient getRedisClient(String clientName, boolean waitEnabled, long w
             client = new Jedis(address, DefaultJedisClientConfig.builder().database(this.dbIndex).connectionTimeoutMillis(this.connectionTimeout)
                     .socketTimeoutMillis(this.socketTimeout).ssl(this.sslEnabled).build());
 
-            if (this.user != null) {
+            if (!Strings.isNullOrEmpty(this.user)) {
                 client.auth(this.user, this.password);
             }
-            else if (this.password != null) {
+            else if (!Strings.isNullOrEmpty(this.password)) {
                 client.auth(this.password);
             }
             else {