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;
+    }
+}