From 4cd477dd6b56ddcc3ca1d42e966197fdde4ac798 Mon Sep 17 00:00:00 2001
From: eizners <sergey.eizner@redis.com>
Date: Thu, 14 Mar 2024 15:52:22 -0400
Subject: [PATCH] DBZ-7646 Support empty or null user/passwords with Redis
 connections

---
 .../main/java/io/debezium/storage/redis/RedisConnection.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/debezium-storage/debezium-storage-redis/src/main/java/io/debezium/storage/redis/RedisConnection.java b/debezium-storage/debezium-storage-redis/src/main/java/io/debezium/storage/redis/RedisConnection.java
index d5e8821cf..ac0e9edfe 100644
--- a/debezium-storage/debezium-storage-redis/src/main/java/io/debezium/storage/redis/RedisConnection.java
+++ b/debezium-storage/debezium-storage-redis/src/main/java/io/debezium/storage/redis/RedisConnection.java
@@ -11,6 +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;
@@ -81,10 +82,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 {