From 8b98cc808c337f20823d344982dc55ab8ed4ce49 Mon Sep 17 00:00:00 2001
From: "review512jwy@163.com" <“review512jwy@163.com”>
Date: Fri, 13 Mar 2026 13:37:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84tcp=E6=B6=88=E8=B4=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datacenter/receiver/listener/RedisStreamConsumer.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 a52fb7a..eb1c27c 100644
--- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
+++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
@@ -50,11 +50,11 @@ public class RedisStreamConsumer {
 
     private final ExecutorService workerExecutor =
             new ThreadPoolExecutor(
-                    32,
-                    128,
+                    16,
+                    64,
                     60,
                     TimeUnit.SECONDS,
-                    new LinkedBlockingQueue<>(20000),
+                    new LinkedBlockingQueue<>(10000),
                     new ThreadPoolExecutor.CallerRunsPolicy()
             );