From b6138afe8bd49f08ef9a051b5ba152752700e771 Mon Sep 17 00:00:00 2001
From: zengqiao <zengqiao@didiglobal.com>
Date: Fri, 5 Jun 2020 16:56:00 +0800
Subject: [PATCH] fix add cluster

---
 .../manager/service/service/impl/ClusterServiceImpl.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ClusterServiceImpl.java b/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ClusterServiceImpl.java
index 05f87c29..5ea8766e 100644
--- a/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ClusterServiceImpl.java
+++ b/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ClusterServiceImpl.java
@@ -10,6 +10,7 @@ import com.xiaojukeji.kafka.manager.dao.ClusterDao;
 import com.xiaojukeji.kafka.manager.dao.ClusterMetricsDao;
 import com.xiaojukeji.kafka.manager.dao.ControllerDao;
 import com.xiaojukeji.kafka.manager.service.cache.ClusterMetadataManager;
+import com.xiaojukeji.kafka.manager.service.schedule.ScheduleCollectDataManager;
 import com.xiaojukeji.kafka.manager.service.service.ClusterService;
 import org.apache.zookeeper.ZooKeeper;
 import org.slf4j.Logger;
@@ -37,6 +38,9 @@ public class ClusterServiceImpl implements ClusterService {
     @Autowired
     private ClusterMetadataManager clusterMetadataManager;
 
+    @Autowired
+    private ScheduleCollectDataManager scheduleCollectDataManager;
+
     @Autowired
     private ControllerDao controllerDao;
 
@@ -57,6 +61,7 @@ public class ClusterServiceImpl implements ClusterService {
         if (!status) {
             return new Result(StatusCode.OPERATION_ERROR, "add zookeeper watch failed");
         }
+        scheduleCollectDataManager.start(clusterDO);
 
         if (clusterDO.getAlarmFlag() == null || clusterDO.getAlarmFlag() <= 0) {
             return new Result();
-- 
GitLab