From 31a5f17408b3aa8ec726f61d4d0d262723952562 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Thu, 8 Sep 2022 13:53:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=97=A7=E5=89=AF=E6=9C=AC?= =?UTF-8?q?=E6=95=B0=E4=B8=BANULL=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../know/streaming/km/common/converter/ReassignConverter.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java index ee67b5c2..9d00febe 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java @@ -170,6 +170,7 @@ public class ReassignConverter { detail.setOriginalBrokerIdList(CommonUtils.string2IntList(subJobPO.getOriginalBrokerIds())); detail.setReassignBrokerIdList(CommonUtils.string2IntList(subJobPO.getReassignBrokerIds())); detail.setStatus(subJobPO.getStatus()); + detail.setOldReplicaNum(detail.getOriginalBrokerIdList().size()); ReassignSubJobExtendData extendData = ConvertUtil.str2ObjByJson(subJobPO.getExtendData(), ReassignSubJobExtendData.class); if (extendData != null) { @@ -217,6 +218,7 @@ public class ReassignConverter { topicDetail.setPresentReplicaNum(partitionDetailList.get(0).getPresentReplicaNum()); topicDetail.setNewReplicaNum(partitionDetailList.get(0).getNewReplicaNum()); + topicDetail.setOldReplicaNum(partitionDetailList.get(0).getOldReplicaNum()); topicDetail.setOriginalRetentionTimeUnitMs(partitionDetailList.get(0).getOriginalRetentionTimeUnitMs()); topicDetail.setReassignRetentionTimeUnitMs(partitionDetailList.get(0).getReassignRetentionTimeUnitMs());