receiver读取PARTITIONS的bug

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) {