From 223c35581dfe5502886ae88efad2f1c848ec1ab6 Mon Sep 17 00:00:00 2001
From: "review512jwy@163.com" <“review512jwy@163.com”>
Date: Wed, 1 Jul 2026 19:17:02 +0800
Subject: [PATCH] =?UTF-8?q?receiver=E8=AF=BB=E5=8F=96PARTITIONS=E7=9A=84bu?=
 =?UTF-8?q?g?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datacenter/receiver/listener/RedisStreamConsumer.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 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 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) {