diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java index 59aa86da..749a687f 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java @@ -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.common.TaskResult; 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.common.bean.entity.cluster.ClusterPhy; import org.springframework.beans.factory.annotation.Autowired; @@ -14,13 +12,11 @@ import org.springframework.beans.factory.annotation.Autowired; */ @Task(name = "ZookeeperMetricCollectorTask", description = "Zookeeper指标采集任务", - cron = "0 0/1 * * * ? *", + cron = "50 0/1 * * * ? *", autoRegister = true, consensual = ConsensualEnum.BROADCAST, timeout = 2 * 60) public class ZookeeperMetricCollectorTask extends AbstractAsyncMetricsDispatchTask { - private static final ILog log = LogFactory.getLog(ZookeeperMetricCollectorTask.class); - @Autowired private ZookeeperMetricCollector zookeeperMetricCollector;