[Feature] #1121 support clearInactiveClusterPhyBrokers

Author: chang-wd

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);
 
 
     /**

km-biz/src/main/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);
     }
 

km-core/src/main/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