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 3906082..a52fb7a 100644
--- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
+++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
@@ -198,7 +198,7 @@ public class RedisStreamConsumer {
                                 Consumer.from(GROUP, consumerName),
                                 StreamReadOptions.empty()
                                         .count(20)
-                                        .block(Duration.ofSeconds(2)),
+                                        .block(Duration.ofSeconds(1)),
                                 StreamOffset.create(stream, ReadOffset.lastConsumed())
                         );