From 3a3141a3615fdfa8093c15f5844546b7ef24b19e Mon Sep 17 00:00:00 2001 From: zengqiao Date: Tue, 6 Dec 2022 16:40:52 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4ZK=E6=8C=87=E6=A0=87=E7=9A=84?= =?UTF-8?q?=E9=87=87=E9=9B=86=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../km/task/kafka/metrics/ZookeeperMetricCollectorTask.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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;