Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
byyunpeng
kafka-manager
提交
fdce41b4
K
kafka-manager
项目概览
byyunpeng
/
kafka-manager
与 Fork 源项目一致
Fork自
DiDi / kafka-manager
通知
2
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
K
kafka-manager
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
fdce41b4
编写于
1月 21, 2022
作者:
X
xuguang
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
增加对定时任务的说明
上级
373680d8
变更
15
隐藏空白更改
内联
并排
Showing
15 changed file
with
31 addition
and
0 deletion
+31
-0
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java
.../manager/service/cache/LogicalClusterMetadataManager.java
+3
-0
kafka-manager-extends/kafka-manager-account/src/main/java/com/xiaojukeji/kafka/manager/account/impl/AccountServiceImpl.java
...jukeji/kafka/manager/account/impl/AccountServiceImpl.java
+3
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java
...om/xiaojukeji/kafka/manager/task/component/Heartbeat.java
+3
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/SyncClusterTaskState.java
...kafka/manager/task/dispatch/biz/SyncClusterTaskState.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java
...ask/dispatch/metrics/collect/CollectAndPublishCGData.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishTopicThrottledMetrics.java
...trics/collect/CollectAndPublishTopicThrottledMetrics.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java
...task/dispatch/metrics/store/StoreDiDiAppTopicMetrics.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java
...patch/metrics/store/StoreDiDiTopicRequestTimeMetrics.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java
.../kafka/manager/task/dispatch/op/AutoHandleTopicOrder.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/listener/SinkCommunityTopicMetrics2Monitor.java
...ager/task/listener/SinkCommunityTopicMetrics2Monitor.java
+1
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/FlushTopicMetrics.java
...jukeji/kafka/manager/task/schedule/FlushTopicMetrics.java
+3
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushBKConsumerGroupMetadata.java
.../task/schedule/metadata/FlushBKConsumerGroupMetadata.java
+3
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushClusterMetadata.java
.../manager/task/schedule/metadata/FlushClusterMetadata.java
+3
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushTopicProperties.java
.../manager/task/schedule/metadata/FlushTopicProperties.java
+3
-0
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushZKConsumerGroupMetadata.java
.../task/schedule/metadata/FlushZKConsumerGroupMetadata.java
+3
-0
未找到文件。
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/cache/LogicalClusterMetadataManager.java
浏览文件 @
fdce41b4
...
...
@@ -156,6 +156,9 @@ public class LogicalClusterMetadataManager {
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
浏览文件 @
fdce41b4
...
...
@@ -275,6 +275,9 @@ public class AccountServiceImpl implements AccountService {
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
浏览文件 @
fdce41b4
...
...
@@ -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
浏览文件 @
fdce41b4
...
...
@@ -17,6 +17,7 @@ import java.util.Arrays;
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
浏览文件 @
fdce41b4
...
...
@@ -28,6 +28,7 @@ import java.util.concurrent.Callable;
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
浏览文件 @
fdce41b4
...
...
@@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
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
浏览文件 @
fdce41b4
...
...
@@ -21,6 +21,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
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
浏览文件 @
fdce41b4
...
...
@@ -21,6 +21,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
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
浏览文件 @
fdce41b4
...
...
@@ -31,6 +31,7 @@ import java.util.List;
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
浏览文件 @
fdce41b4
...
...
@@ -26,6 +26,7 @@ import java.util.Arrays;
import
java.util.List
;
/**
* 定时上报Topic监控指标
* @author zengqiao
* @date 20/8/10
*/
...
...
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/FlushTopicMetrics.java
浏览文件 @
fdce41b4
...
...
@@ -30,6 +30,9 @@ public class FlushTopicMetrics {
@Autowired
private
ClusterService
clusterService
;
/**
* 定时刷新topic指标到缓存中
*/
@Scheduled
(
cron
=
"5 0/1 * * * ?"
)
public
void
flushTopicMetrics
()
{
long
startTime
=
System
.
currentTimeMillis
();
...
...
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushBKConsumerGroupMetadata.java
浏览文件 @
fdce41b4
...
...
@@ -30,6 +30,9 @@ public class FlushBKConsumerGroupMetadata {
@Autowired
private
ClusterService
clusterService
;
/**
* 定时刷新broker上消费组信息到缓存中
*/
@Scheduled
(
cron
=
"15 0/1 * * * ?"
)
public
void
schedule
()
{
List
<
ClusterDO
>
doList
=
clusterService
.
list
();
...
...
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushClusterMetadata.java
浏览文件 @
fdce41b4
...
...
@@ -25,6 +25,9 @@ public class FlushClusterMetadata {
@Autowired
private
PhysicalClusterMetadataManager
physicalClusterMetadataManager
;
/**
* 定时刷新物理集群元信息到缓存中
*/
@Scheduled
(
cron
=
"0/30 * * * * ?"
)
public
void
flush
()
{
Map
<
Long
,
ClusterDO
>
dbClusterMap
=
clusterService
.
list
().
stream
().
collect
(
Collectors
.
toMap
(
ClusterDO:
:
getId
,
Function
.
identity
(),
(
key1
,
key2
)
->
key2
));
...
...
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushTopicProperties.java
浏览文件 @
fdce41b4
...
...
@@ -27,6 +27,9 @@ public class FlushTopicProperties {
@Autowired
private
ClusterService
clusterService
;
/**
* 定时刷新物理集群配置到缓存中
*/
@Scheduled
(
cron
=
"25 0/1 * * * ?"
)
public
void
flush
()
{
List
<
ClusterDO
>
doList
=
clusterService
.
list
();
...
...
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/schedule/metadata/FlushZKConsumerGroupMetadata.java
浏览文件 @
fdce41b4
...
...
@@ -35,6 +35,9 @@ public class FlushZKConsumerGroupMetadata {
@Autowired
private
ThreadPool
threadPool
;
/**
* 定时刷新zk上的消费组信息到缓存中
*/
@Scheduled
(
cron
=
"35 0/1 * * * ?"
)
public
void
schedule
()
{
List
<
ClusterDO
>
doList
=
clusterService
.
list
();
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录