From d550fc506858f4bc03e18744e643ed23769050b6 Mon Sep 17 00:00:00 2001
From: GraceWalk <gracewalk1999@163.com>
Date: Tue, 13 Sep 2022 14:24:30 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20Consume=20=E7=82=B9?=
 =?UTF-8?q?=E5=87=BB=20Stop=20=E5=90=8E=E6=9C=AA=E5=81=9C=E6=AD=A2?=
 =?UTF-8?q?=E8=AF=B7=E6=B1=82=E5=8F=91=E9=80=81=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/pages/TestingConsumer/Consume.tsx     | 53 +++++++++----------
 1 file changed, 25 insertions(+), 28 deletions(-)

diff --git a/km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx b/km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx
index 5ec957a6..d74d723f 100644
--- a/km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx
+++ b/km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx
@@ -178,38 +178,35 @@ const ConsumeClientTest = () => {
     partitionProcessRef.current = processList;
 
     curPartitionList.current = _partitionList;
-
-    switch (until) {
-      case 'timestamp':
-        setIsStop(currentTime >= untilDate);
-        isStopStatus.current = currentTime >= untilDate;
-        break;
-      case 'number of messages':
-        setIsStop(+recordCountCur.current >= untilMsgNum);
-        isStopStatus.current = +recordCountCur.current >= untilMsgNum;
-        break;
-      case 'number of messages per partition': // 所有分区都达到了设定值
-        // 过滤出消费数量不足设定值的partition
-        const filtersPartition = _partitionList.filter((item: any) => item.recordCount < untilMsgNum);
-        curPartitionList.current = filtersPartition; // 用作下一次请求的入参
-        if (!isStop) {
+    if (!isStopStatus.current) {
+      switch (until) {
+        case 'timestamp':
+          setIsStop(currentTime >= untilDate);
+          isStopStatus.current = currentTime >= untilDate;
+          break;
+        case 'number of messages':
+          setIsStop(+recordCountCur.current >= untilMsgNum);
+          isStopStatus.current = +recordCountCur.current >= untilMsgNum;
+          break;
+        case 'number of messages per partition': // 所有分区都达到了设定值
+          // 过滤出消费数量不足设定值的partition
+          const filtersPartition = _partitionList.filter((item: any) => item.recordCount < untilMsgNum);
+          curPartitionList.current = filtersPartition; // 用作下一次请求的入参
           setIsStop(filtersPartition.length < 1);
           isStopStatus.current = filtersPartition.length < 1;
-        }
-        break;
-      case 'max size':
-        setIsStop(+recordSizeCur.current >= unitMsgSize);
-        isStopStatus.current = +recordSizeCur.current >= unitMsgSize;
-        break;
-      case 'max size per partition':
-        // 过滤出消费size不足设定值的partition
-        const filters = partitionConsumedList.filter((item: any) => item.recordSizeUnitB < unitMsgSize);
-        if (!isStop) {
+          break;
+        case 'max size':
+          setIsStop(+recordSizeCur.current >= unitMsgSize);
+          isStopStatus.current = +recordSizeCur.current >= unitMsgSize;
+          break;
+        case 'max size per partition':
+          // 过滤出消费size不足设定值的partition
+          const filters = partitionConsumedList.filter((item: any) => item.recordSizeUnitB < unitMsgSize);
           setIsStop(filters.length < 1);
           isStopStatus.current = filters.length < 1;
-        }
-        curPartitionList.current = filters;
-        break;
+          curPartitionList.current = filters;
+          break;
+      }
     }
   };