From 7d045dbf05bdf6ecd470aba1c53c8312c185eab6 Mon Sep 17 00:00:00 2001
From: zengqiao <zengqiao@didiglobal.com>
Date: Sat, 29 Oct 2022 13:52:16 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85ZK=E5=81=A5=E5=BA=B7=E5=B7=A1?=
 =?UTF-8?q?=E6=A3=80=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../task/health/ZookeeperHealthCheckTask.java | 28 +++++++++++++++++++
 1 file changed, 28 insertions(+)
 create mode 100644 km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ZookeeperHealthCheckTask.java

diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ZookeeperHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ZookeeperHealthCheckTask.java
new file mode 100644
index 00000000..89a1c4f3
--- /dev/null
+++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ZookeeperHealthCheckTask.java
@@ -0,0 +1,28 @@
+package com.xiaojukeji.know.streaming.km.task.health;
+
+import com.didiglobal.logi.job.annotation.Task;
+import com.didiglobal.logi.job.core.consensual.ConsensualEnum;
+import com.xiaojukeji.know.streaming.km.core.service.health.checker.AbstractHealthCheckService;
+import com.xiaojukeji.know.streaming.km.core.service.health.checker.zookeeper.HealthCheckZookeeperService;
+import lombok.AllArgsConstructor;
+import lombok.NoArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Task(name = "ZookeeperHealthCheckTask",
+        description = "Zookeeper健康检查",
+        cron = "0 0/1 * * * ? *",
+        autoRegister = true,
+        consensual = ConsensualEnum.BROADCAST,
+        timeout = 2 * 60)
+public class ZookeeperHealthCheckTask extends AbstractHealthCheckTask {
+    @Autowired
+    private HealthCheckZookeeperService healthCheckZookeeperService;
+
+    @Override
+    public AbstractHealthCheckService getCheckService() {
+        return healthCheckZookeeperService;
+    }
+}