8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 03:42:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: 修复 Consumer 点击 Stop 不发停止检索问题修复

Browse Source
This commit is contained in:
GraceWalk
2022-09-01 19:50:04 +08:00
parent 0043ab8371
commit 8281301cbd
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx
View File

@@ -192,8 +192,10 @@ const ConsumeClientTest = () => {
// 过滤出消费数量不足设定值的partition
const filtersPartition = _partitionList.filter((item: any) => item.recordCount < untilMsgNum);
curPartitionList.current = filtersPartition; // 用作下一次请求的入参
setIsStop(filtersPartition.length < 1);
isStopStatus.current = filtersPartition.length < 1;
if (!isStop) {
setIsStop(filtersPartition.length < 1);
isStopStatus.current = filtersPartition.length < 1;
}
break;
case 'max size':
setIsStop(+recordSizeCur.current >= unitMsgSize);
@@ -202,8 +204,10 @@ const ConsumeClientTest = () => {
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;
if (!isStop) {
setIsStop(filters.length < 1);
isStopStatus.current = filters.length < 1;
}
curPartitionList.current = filters;
break;
}