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 1f059eb..1a86b7e 100644
--- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
+++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
@@ -85,7 +85,7 @@ public class RedisStreamConsumer {
         consumerName = buildConsumerName();
         log.info("RedisStreamConsumer start, consumer={}", consumerName);
 
-        for (int i = 0; i < PARTITIONS; i++) {
+        for (int i = 1; i <= PARTITIONS; i++) {
             String stream = STREAM_PREFIX + i;
 
             cleanConsumers(stream);
@@ -292,7 +292,7 @@ public class RedisStreamConsumer {
      * 防止消息被遗忘或丢失
      */
     private void reclaimIdleMessages() {
-        for (int i = 0; i < PARTITIONS; i++) {
+        for (int i = 1; i <= PARTITIONS; i++) {
             String stream = STREAM_PREFIX + i;
             try {
                 while (true) {