From 2341784be7d8b0014e22e929d02f3ba17c49c7ac Mon Sep 17 00:00:00 2001 From: "review512jwy@163.com" <“review512jwy@163.com”> Date: Sun, 8 Mar 2026 16:47:25 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E6=94=B6tcp?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datacenter/receiver/listener/RedisStreamConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java index e03e761..8dc57c9 100644 --- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java +++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java @@ -421,7 +421,7 @@ public class RedisStreamConsumer { boolean reclaimTerminated = reclaimScheduler.awaitTermination(10, TimeUnit.SECONDS); - log.info("RedisStreamConsumer shutdown done, consumerTerminated={}, workerTterminated={}, reclaimTerminated={}", + log.info("RedisStreamConsumer shutdown done, consumerTerminated={}, workerTerminated={}, reclaimTerminated={}", consumerTerminated, workerTerminated, reclaimTerminated);