From 19b7f6ad8c4df0aeaeb459f0c208ba069f4d4853 Mon Sep 17 00:00:00 2001 From: didi <1643482336@qq.com> Date: Tue, 14 Dec 2021 18:32:14 +0800 Subject: [PATCH] =?UTF-8?q?RegionService=E4=B8=8B=E7=9A=84updateRegion?= =?UTF-8?q?=E7=9A=84=E9=87=8D=E8=BD=BD=E6=96=B9=E6=B3=95=E5=90=AB=E4=B9=89?= =?UTF-8?q?=E9=94=99=E8=AF=AF;=E5=BA=94=E8=AF=A5=E6=98=AF=E6=A0=B9?= =?UTF-8?q?=E6=8D=AEregionId=E6=9B=B4=E6=96=B0region=EF=BC=8C=E5=8F=82?= =?UTF-8?q?=E6=95=B0=E5=BA=94=E8=AF=A5=E6=98=AFregionId=EF=BC=8C=E4=B8=8D?= =?UTF-8?q?=E6=98=AFclusterId?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kafka/manager/service/service/RegionService.java | 6 +++--- .../manager/service/service/impl/RegionServiceImpl.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/RegionService.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/RegionService.java index 40c92a5c..66644eb0 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/RegionService.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/RegionService.java @@ -54,12 +54,12 @@ public interface RegionService { Map convert2BrokerIdRegionMap(List regionDOList); /** - * 更新逻辑集群容量 - * @param clusterId 集群id + * 根据RegionId更新Region + * @param regionId region的id * @param newBrokerList 新的broker列表 * @return ResultStatus */ - ResultStatus updateRegion(Long clusterId, String newBrokerList); + ResultStatus updateRegion(Long regionId, String newBrokerList); /** * 获取空闲的region的broker列表 diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/RegionServiceImpl.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/RegionServiceImpl.java index 8f957b02..b468f873 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/RegionServiceImpl.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/RegionServiceImpl.java @@ -134,11 +134,11 @@ public class RegionServiceImpl implements RegionService { @Override - public ResultStatus updateRegion(Long clusterId, String newBrokerList) { - if (ValidateUtils.isNull(clusterId) || ValidateUtils.isExistBlank(newBrokerList)) { + public ResultStatus updateRegion(Long regionId, String newBrokerList) { + if (ValidateUtils.isNull(regionId) || ValidateUtils.isExistBlank(newBrokerList)) { return ResultStatus.PARAM_ILLEGAL; } - RegionDO regionDO = getById(clusterId); + RegionDO regionDO = getById(regionId); if (ValidateUtils.isNull(regionDO)) { return ResultStatus.CLUSTER_NOT_EXIST; }