[Feature] #1121 support clearInactiveClusterPhyBrokers

didi · Nov 20, 2024 · aaf10ae · aaf10ae
1 parent 43aca84
commit aaf10ae
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterBrokersManager.java b/km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterBrokersManager.java
@@ -24,7 +24,7 @@ public interface ClusterBrokersManager {
      * @param dto 封装分页查询参数对象
      * @return 返回获取到的缓存查询结果 & broker 表查询结果并集
      */
-    PaginationResult<ClusterBrokersOverviewVO> deleteInactiveClusterPhyBrokers(Long clusterPhyId, ClusterBrokersOverviewDTO dto);
+    PaginationResult<ClusterBrokersOverviewVO> clearInactiveClusterPhyBrokers(Long clusterPhyId, ClusterBrokersOverviewDTO dto);
 
 
     /**

diff --git a/...ain/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java b/...ain/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java
@@ -108,8 +108,8 @@ public PaginationResult<ClusterBrokersOverviewVO> getClusterPhyBrokersOverview(L
     }
 
     @Override
-    public PaginationResult<ClusterBrokersOverviewVO> deleteInactiveClusterPhyBrokers(Long clusterPhyId, ClusterBrokersOverviewDTO dto) {
-        brokerService.deleteInactiveClusterPhyBrokers(clusterPhyId);
+    public PaginationResult<ClusterBrokersOverviewVO> clearInactiveClusterPhyBrokers(Long clusterPhyId, ClusterBrokersOverviewDTO dto) {
+        brokerService.clearInactiveClusterPhyBrokers(clusterPhyId);
         return this.getClusterPhyBrokersOverview(clusterPhyId, dto);
     }
 

diff --git a/...ain/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java b/...ain/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java
@@ -187,7 +187,7 @@ public void clearInactiveClusterPhyBrokers(Long clusterPhyId) {
                 .filter(elem -> elem.getStatus().equals(Constant.DOWN))
                 .forEach(elem -> brokerDAO.deleteById(elem.getId()));
         } catch (Exception e) {
-            log.error("method=deleteInactiveClusterPhyBrokers||clusterPhyId={}||errMsg=exception!", clusterPhyId, e);
+            log.error("method=clearInactiveClusterPhyBrokers||clusterPhyId={}||errMsg=exception!", clusterPhyId, e);
         }
     }
     @Override