From aadf431c4040c9e9dd7fa516334229739106a6ea Mon Sep 17 00:00:00 2001 From: Nikolay Angelov Date: Tue, 13 May 2025 13:14:46 +0300 Subject: [PATCH] Update RedisStreamChangeConsumer to use the new constructor for RedisConnection --- .../io/debezium/server/redis/RedisStreamChangeConsumer.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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());