diff --git a/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisStreamChangeConsumer.java b/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisStreamChangeConsumer.java
index e11509114..cfda881f6 100644
--- a/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisStreamChangeConsumer.java
+++ b/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisStreamChangeConsumer.java
@@ -95,9 +95,7 @@ else if (MESSAGE_FORMAT_COMPACT.equals(messageFormat)) {
             };
         }
 
-        RedisConnection redisConnection = new RedisConnection(config.getAddress(), config.getDbIndex(),
-                config.getUser(), config.getPassword(), config.getConnectionTimeout(), config.getSocketTimeout(),
-                config.isSslEnabled(), config.isHostnameVerificationEnabled());
+        RedisConnection redisConnection = new RedisConnection(config);
         client = redisConnection.getRedisClient(DEBEZIUM_REDIS_SINK_CLIENT_NAME, config.isWaitEnabled(),
                 config.getWaitTimeout(), config.isWaitRetryEnabled(), config.getWaitRetryDelay());