增加对定时任务的说明

Author: xuguang

kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java

@@ -156,6 +156,9 @@ public Long getPhysicalClusterId(Long clusterId, Boolean isPhysicalClusterId) {
         return logicalClusterDO.getClusterId();
     }
 
+    /**
+     * 定时刷新逻辑集群元数据到缓存中
+     */
     @Scheduled(cron="0/30 * * * * ?")
     public void flush() {
         List<LogicalClusterDO> logicalClusterDOList = logicalClusterService.listAll();

kafka-manager-extends/kafka-manager-account/src/main/java/com/xiaojukeji/kafka/manager/account/impl/AccountServiceImpl.java

@@ -275,6 +275,9 @@ public List<EnterpriseStaff> searchAccountByPrefix(String prefix) {
         return enterpriseStaffService.searchEnterpriseStaffByKeyWord(prefix);
     }
 
+    /**
+     * 定时刷新account信息到缓存中
+     */
     @Scheduled(cron ="0/5 * * * * ?")
     public void flush() {
         try {

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java

@@ -23,6 +23,9 @@ public class Heartbeat {
     @Autowired
     private HeartbeatDao heartbeatDao;
 
+    /**
+     * 定时获取管控平台所在机器IP等信息到DB
+     */
     @Scheduled(cron = ScheduledTaskConstant.HEARTBEAT_CRON)
     public void ipFlush() {
         try {

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/SyncClusterTaskState.java

@@ -17,6 +17,7 @@
 import java.util.List;
 
 /**
+ * 同步更新集群任务状态
  * @author zengqiao
  * @date 20/9/7
  */

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java

@@ -28,6 +28,7 @@
 import java.util.concurrent.FutureTask;
 
 /**
+ * 收集并发布消费者指标数据
  * @author zengqiao
  * @date 20/9/14
  */

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishTopicThrottledMetrics.java

@@ -16,6 +16,7 @@
 import java.util.*;
 
 /**
+ * 收集和发布Topic限流信息
  * @author zengqiao
  * @date 2019-05-10
  */

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java

@@ -21,6 +21,7 @@
 import java.util.*;
 
 /**
+ * JMX中获取appId维度的流量信息存DB
  * @author zengqiao
  * @date 20/7/21
  */

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java

@@ -21,6 +21,7 @@
 import java.util.*;
 
 /**
+ * JMX中获取的TopicRequestTimeMetrics信息存DB
  * @author zengqiao
  * @date 20/7/21
  */

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java

@@ -31,6 +31,7 @@
 import java.util.Properties;
 
 /**
+ * 定时自动处理Topic相关工单
  * @author zengqiao
  * @date 20/7/28
  */

kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/listener/SinkCommunityTopicMetrics2Monitor.java

@@ -26,6 +26,7 @@
 import java.util.List;
 
 /**
+ * 定时上报Topic监控指标
  * @author zengqiao
  * @date 20/8/10
  */