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()
             );