From f4b2a3c0af1f22c7fa65428257572e043ee1cad1 Mon Sep 17 00:00:00 2001 From: eizners Date: Fri, 19 Jan 2024 09:50:57 -0500 Subject: [PATCH] DBZ-7117 change log message --- .../io/debezium/server/redis/RedisStreamChangeConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 2e6fe4f7..ec74f5fc 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 @@ -214,7 +214,7 @@ public void handleBatch(List> records, clonedBatch.removeAll(processedRecords); if (totalOOMResponses > 0) { - LOGGER.info("Redis sink currently full, will retry ({} command(s) failed)", + LOGGER.info("Redis sink currently full, will retry ({} command(s) will be retried)", totalOOMResponses); }