From fdce41b45110e647c9726778f5e42f1178d17c3b Mon Sep 17 00:00:00 2001 From: xuguang Date: Fri, 21 Jan 2022 10:50:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=AF=B9=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E7=9A=84=E8=AF=B4=E6=98=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../manager/service/cache/LogicalClusterMetadataManager.java | 3 +++ .../kafka/manager/account/impl/AccountServiceImpl.java | 3 +++ .../com/xiaojukeji/kafka/manager/task/component/Heartbeat.java | 3 +++ .../kafka/manager/task/dispatch/biz/SyncClusterTaskState.java | 1 + .../task/dispatch/metrics/collect/CollectAndPublishCGData.java | 1 + .../collect/CollectAndPublishTopicThrottledMetrics.java | 1 + .../task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java | 1 + .../metrics/store/StoreDiDiTopicRequestTimeMetrics.java | 1 + .../kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java | 1 + .../task/listener/SinkCommunityTopicMetrics2Monitor.java | 1 + .../kafka/manager/task/schedule/FlushTopicMetrics.java | 3 +++ .../task/schedule/metadata/FlushBKConsumerGroupMetadata.java | 3 +++ .../manager/task/schedule/metadata/FlushClusterMetadata.java | 3 +++ .../manager/task/schedule/metadata/FlushTopicProperties.java | 3 +++ .../task/schedule/metadata/FlushZKConsumerGroupMetadata.java | 3 +++ 15 files changed, 31 insertions(+) diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java index d58efc9a..2c47db7e 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java @@ -156,6 +156,9 @@ public class LogicalClusterMetadataManager { return logicalClusterDO.getClusterId(); } + /** + * 定时刷新逻辑集群元数据到缓存中 + */ @Scheduled(cron="0/30 * * * * ?") public void flush() { List logicalClusterDOList = logicalClusterService.listAll(); diff --git a/kafka-manager-extends/kafka-manager-account/src/main/java/com/xiaojukeji/kafka/manager/account/impl/AccountServiceImpl.java b/kafka-manager-extends/kafka-manager-account/src/main/java/com/xiaojukeji/kafka/manager/account/impl/AccountServiceImpl.java index e4d03c23..07d10a64 100644 --- a/kafka-manager-extends/kafka-manager-account/src/main/java/com/xiaojukeji/kafka/manager/account/impl/AccountServiceImpl.java +++ b/kafka-manager-extends/kafka-manager-account/src/main/java/com/xiaojukeji/kafka/manager/account/impl/AccountServiceImpl.java @@ -275,6 +275,9 @@ public class AccountServiceImpl implements AccountService { return enterpriseStaffService.searchEnterpriseStaffByKeyWord(prefix); } + /** + * 定时刷新account信息到缓存中 + */ @Scheduled(cron ="0/5 * * * * ?") public void flush() { try { diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java index d00c0ad0..c6009795 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java +++ b/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 { diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/SyncClusterTaskState.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/SyncClusterTaskState.java index 9edddb28..43f991d7 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/SyncClusterTaskState.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/SyncClusterTaskState.java @@ -17,6 +17,7 @@ import java.util.Arrays; import java.util.List; /** + * 同步更新集群任务状态 * @author zengqiao * @date 20/9/7 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java index 28bb1612..4a54a842 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java @@ -28,6 +28,7 @@ import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; /** + * 收集并发布消费者指标数据 * @author zengqiao * @date 20/9/14 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishTopicThrottledMetrics.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishTopicThrottledMetrics.java index 27cf68c1..6c77de82 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishTopicThrottledMetrics.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishTopicThrottledMetrics.java @@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired; import java.util.*; /** + * 收集和发布Topic限流信息 * @author zengqiao * @date 2019-05-10 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java index 6543f6fa..0ca2f7b2 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java @@ -21,6 +21,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import java.util.*; /** + * JMX中获取appId维度的流量信息存DB * @author zengqiao * @date 20/7/21 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java index 040612f2..b3f8d365 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java @@ -21,6 +21,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import java.util.*; /** + * JMX中获取的TopicRequestTimeMetrics信息存DB * @author zengqiao * @date 20/7/21 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java index 46158b60..346f4a3d 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java @@ -31,6 +31,7 @@ import java.util.List; import java.util.Properties; /** + * 定时自动处理Topic相关工单 * @author zengqiao * @date 20/7/28 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/listener/SinkCommunityTopicMetrics2Monitor.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/listener/SinkCommunityTopicMetrics2Monitor.java index e2ac74a9..2ebd522d 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/listener/SinkCommunityTopicMetrics2Monitor.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/listener/SinkCommunityTopicMetrics2Monitor.java @@ -26,6 +26,7 @@ import java.util.Arrays; import java.util.List; /** + * 定时上报Topic监控指标 * @author zengqiao * @date 20/8/10 */ diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/FlushTopicMetrics.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/FlushTopicMetrics.java index affb03e4..fe56f933 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/FlushTopicMetrics.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/FlushTopicMetrics.java @@ -30,6 +30,9 @@ public class FlushTopicMetrics { @Autowired private ClusterService clusterService; + /** + * 定时刷新topic指标到缓存中 + */ @Scheduled(cron="5 0/1 * * * ?") public void flushTopicMetrics() { long startTime = System.currentTimeMillis(); diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushBKConsumerGroupMetadata.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushBKConsumerGroupMetadata.java index 239c3ed0..001d8865 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushBKConsumerGroupMetadata.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushBKConsumerGroupMetadata.java @@ -30,6 +30,9 @@ public class FlushBKConsumerGroupMetadata { @Autowired private ClusterService clusterService; + /** + * 定时刷新broker上消费组信息到缓存中 + */ @Scheduled(cron="15 0/1 * * * ?") public void schedule() { List doList = clusterService.list(); diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushClusterMetadata.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushClusterMetadata.java index e88ad696..416b392d 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushClusterMetadata.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushClusterMetadata.java @@ -25,6 +25,9 @@ public class FlushClusterMetadata { @Autowired private PhysicalClusterMetadataManager physicalClusterMetadataManager; + /** + * 定时刷新物理集群元信息到缓存中 + */ @Scheduled(cron="0/30 * * * * ?") public void flush() { Map dbClusterMap = clusterService.list().stream().collect(Collectors.toMap(ClusterDO::getId, Function.identity(), (key1, key2) -> key2)); diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushTopicProperties.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushTopicProperties.java index 41a8bde4..b504f609 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushTopicProperties.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushTopicProperties.java @@ -27,6 +27,9 @@ public class FlushTopicProperties { @Autowired private ClusterService clusterService; + /** + * 定时刷新物理集群配置到缓存中 + */ @Scheduled(cron="25 0/1 * * * ?") public void flush() { List doList = clusterService.list(); diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushZKConsumerGroupMetadata.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushZKConsumerGroupMetadata.java index 54321240..397fba7e 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushZKConsumerGroupMetadata.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushZKConsumerGroupMetadata.java @@ -35,6 +35,9 @@ public class FlushZKConsumerGroupMetadata { @Autowired private ThreadPool threadPool; + /** + * 定时刷新zk上的消费组信息到缓存中 + */ @Scheduled(cron="35 0/1 * * * ?") public void schedule() { List doList = clusterService.list();