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; }