8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

调整ZK指标的采集时间

Browse Source
This commit is contained in:
zengqiao
2022-12-06 16:40:52 +08:00
parent ac30436324
commit 3a3141a361
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java
View File

@@ -3,8 +3,6 @@ package com.xiaojukeji.know.streaming.km.task.kafka.metrics;
import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.annotation.Task;
import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.job.common.TaskResult;
import com.didiglobal.logi.job.core.consensual.ConsensualEnum; import com.didiglobal.logi.job.core.consensual.ConsensualEnum;
import com.didiglobal.logi.log.ILog;
import com.didiglobal.logi.log.LogFactory;
import com.xiaojukeji.know.streaming.km.collector.metric.kafka.ZookeeperMetricCollector; import com.xiaojukeji.know.streaming.km.collector.metric.kafka.ZookeeperMetricCollector;
import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -14,13 +12,11 @@ import org.springframework.beans.factory.annotation.Autowired;
*/ */
@Task(name = "ZookeeperMetricCollectorTask", @Task(name = "ZookeeperMetricCollectorTask",
description = "Zookeeper指标采集任务", description = "Zookeeper指标采集任务",
cron = "0 0/1 * * * ? *", cron = "50 0/1 * * * ? *",
autoRegister = true, autoRegister = true,
consensual = ConsensualEnum.BROADCAST, consensual = ConsensualEnum.BROADCAST,
timeout = 2 * 60) timeout = 2 * 60)
public class ZookeeperMetricCollectorTask extends AbstractAsyncMetricsDispatchTask { public class ZookeeperMetricCollectorTask extends AbstractAsyncMetricsDispatchTask {
private static final ILog log = LogFactory.getLog(ZookeeperMetricCollectorTask.class);
@Autowired @Autowired
private ZookeeperMetricCollector zookeeperMetricCollector; private ZookeeperMetricCollector zookeeperMetricCollector;