From da0a97cabf8641cdffe25be6a063daaae8b207a2 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Tue, 8 Nov 2022 10:33:30 +0800 Subject: [PATCH] =?UTF-8?q?[Optimize]=20=E8=B0=83=E6=95=B4Task=E4=BB=A3?= =?UTF-8?q?=E7=A0=81=E7=BB=93=E6=9E=84=E4=B8=BAConnector=E5=8A=9F=E8=83=BD?= =?UTF-8?q?=E5=81=9A=E5=87=86=E5=A4=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../entity/{EntifyIdInterface.java => EntityIdInterface.java} | 2 +- .../streaming/km/common/bean/entity/cluster/ClusterPhy.java | 4 ++-- .../know/streaming/km/task/AbstractDispatchTask.java | 4 ++-- .../km/task/{ => kafka}/AbstractAsyncCommonDispatchTask.java | 2 +- .../km/task/{ => kafka}/AbstractClusterPhyDispatchTask.java | 3 ++- .../km/task/{ => kafka}/client/CheckJmxClientTask.java | 2 +- .../km/task/{ => kafka}/health/AbstractHealthCheckTask.java | 4 ++-- .../km/task/{ => kafka}/health/BrokerHealthCheckTask.java | 2 +- .../km/task/{ => kafka}/health/ClusterHealthCheckTask.java | 2 +- .../km/task/{ => kafka}/health/GroupHealthCheckTask.java | 2 +- .../km/task/{ => kafka}/health/TopicHealthCheckTask.java | 2 +- .../km/task/{ => kafka}/health/ZookeeperHealthCheckTask.java | 2 +- .../km/task/{ => kafka}/job/CommunityReassignJobTask.java | 4 ++-- .../know/streaming/km/task/{ => kafka}/job/KMJobTask.java | 4 ++-- .../metadata/AbstractAsyncMetadataDispatchTask.java | 4 ++-- .../task/{ => kafka}/metadata/SyncBrokerConfigDiffTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncBrokerTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncControllerTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncKafkaAclTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncKafkaGroupTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncKafkaUserTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncPartitionTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncTopicConfigTask.java | 2 +- .../streaming/km/task/{ => kafka}/metadata/SyncTopicTask.java | 2 +- .../km/task/{ => kafka}/metadata/SyncZookeeperTask.java | 2 +- .../{ => kafka}/metrics/AbstractAsyncMetricsDispatchTask.java | 4 ++-- .../task/{ => kafka}/metrics/BrokerMetricCollectorTask.java | 2 +- .../task/{ => kafka}/metrics/ClusterMetricCollectorTask.java | 2 +- .../km/task/{ => kafka}/metrics/GroupMetricCollectorTask.java | 2 +- .../{ => kafka}/metrics/PartitionMetricCollectorTask.java | 2 +- .../task/{ => kafka}/metrics/ReplicaMetricCollectorTask.java | 2 +- .../km/task/{ => kafka}/metrics/TopicMetricCollectorTask.java | 2 +- .../{ => kafka}/metrics/ZookeeperMetricCollectorTask.java | 2 +- .../km/task/service/listener/TaskClusterAddedListener.java | 4 ++-- 34 files changed, 43 insertions(+), 42 deletions(-) rename km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/{EntifyIdInterface.java => EntityIdInterface.java} (80%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/AbstractAsyncCommonDispatchTask.java (97%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/AbstractClusterPhyDispatchTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/client/CheckJmxClientTask.java (97%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/health/AbstractHealthCheckTask.java (97%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/health/BrokerHealthCheckTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/health/ClusterHealthCheckTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/health/GroupHealthCheckTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/health/TopicHealthCheckTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/health/ZookeeperHealthCheckTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/job/CommunityReassignJobTask.java (92%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/job/KMJobTask.java (86%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/AbstractAsyncMetadataDispatchTask.java (93%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncBrokerConfigDiffTask.java (98%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncBrokerTask.java (96%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncControllerTask.java (96%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncKafkaAclTask.java (97%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncKafkaGroupTask.java (98%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncKafkaUserTask.java (96%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncPartitionTask.java (97%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncTopicConfigTask.java (98%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncTopicTask.java (96%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metadata/SyncZookeeperTask.java (96%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/AbstractAsyncMetricsDispatchTask.java (93%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/BrokerMetricCollectorTask.java (95%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/ClusterMetricCollectorTask.java (95%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/GroupMetricCollectorTask.java (95%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/PartitionMetricCollectorTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/ReplicaMetricCollectorTask.java (94%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/TopicMetricCollectorTask.java (95%) rename km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/{ => kafka}/metrics/ZookeeperMetricCollectorTask.java (95%) diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntifyIdInterface.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntityIdInterface.java similarity index 80% rename from km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntifyIdInterface.java rename to km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntityIdInterface.java index c6b42615..2f40f39c 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntifyIdInterface.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntityIdInterface.java @@ -3,7 +3,7 @@ package com.xiaojukeji.know.streaming.km.common.bean.entity; /** * @author didi */ -public interface EntifyIdInterface { +public interface EntityIdInterface { /** * 获取id * @return diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/cluster/ClusterPhy.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/cluster/ClusterPhy.java index 823ec67d..a534a015 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/cluster/ClusterPhy.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/cluster/ClusterPhy.java @@ -1,6 +1,6 @@ package com.xiaojukeji.know.streaming.km.common.bean.entity.cluster; -import com.xiaojukeji.know.streaming.km.common.bean.entity.EntifyIdInterface; +import com.xiaojukeji.know.streaming.km.common.bean.entity.EntityIdInterface; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; @@ -10,7 +10,7 @@ import java.util.Date; @Data @NoArgsConstructor @AllArgsConstructor -public class ClusterPhy implements Comparable, EntifyIdInterface { +public class ClusterPhy implements Comparable, EntityIdInterface { /** * 主键 */ diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java index 6fce1bb3..fc211c14 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java @@ -7,7 +7,7 @@ import com.didiglobal.logi.job.core.job.Job; import com.didiglobal.logi.job.core.job.JobContext; import com.didiglobal.logi.log.ILog; import com.didiglobal.logi.log.LogFactory; -import com.xiaojukeji.know.streaming.km.common.bean.entity.EntifyIdInterface; +import com.xiaojukeji.know.streaming.km.common.bean.entity.EntityIdInterface; import com.xiaojukeji.know.streaming.km.common.exception.AdminTaskCodeException; import com.xiaojukeji.know.streaming.km.common.utils.ValidateUtils; @@ -16,7 +16,7 @@ import java.util.ArrayList; import java.util.Collections; import java.util.List; -public abstract class AbstractDispatchTask implements Job { +public abstract class AbstractDispatchTask implements Job { private static final ILog LOGGER = LogFactory.getLog(AbstractDispatchTask.class); /** diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractAsyncCommonDispatchTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractAsyncCommonDispatchTask.java similarity index 97% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractAsyncCommonDispatchTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractAsyncCommonDispatchTask.java index 0f8f5797..5a41aadc 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractAsyncCommonDispatchTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractAsyncCommonDispatchTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task; +package com.xiaojukeji.know.streaming.km.task.kafka; import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.log.ILog; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractClusterPhyDispatchTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractClusterPhyDispatchTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java index 9281be8c..a9b70748 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractClusterPhyDispatchTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java @@ -1,10 +1,11 @@ -package com.xiaojukeji.know.streaming.km.task; +package com.xiaojukeji.know.streaming.km.task.kafka; import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.log.ILog; import com.didiglobal.logi.log.LogFactory; import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; import com.xiaojukeji.know.streaming.km.core.service.cluster.ClusterPhyService; +import com.xiaojukeji.know.streaming.km.task.AbstractDispatchTask; import org.springframework.beans.factory.annotation.Autowired; import java.util.List; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/client/CheckJmxClientTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/client/CheckJmxClientTask.java similarity index 97% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/client/CheckJmxClientTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/client/CheckJmxClientTask.java index 4e5038a6..2e67fcaa 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/client/CheckJmxClientTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/client/CheckJmxClientTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.client; +package com.xiaojukeji.know.streaming.km.task.kafka.client; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java similarity index 97% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java index 711a4ef6..3c9fdf23 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.health; +package com.xiaojukeji.know.streaming.km.task.kafka.health; import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.log.ILog; @@ -12,7 +12,7 @@ import com.xiaojukeji.know.streaming.km.common.enums.health.HealthCheckDimension import com.xiaojukeji.know.streaming.km.common.utils.ValidateUtils; import com.xiaojukeji.know.streaming.km.core.service.health.checker.AbstractHealthCheckService; import com.xiaojukeji.know.streaming.km.core.service.health.checkresult.HealthCheckResultService; -import com.xiaojukeji.know.streaming.km.task.metrics.AbstractAsyncMetricsDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.metrics.AbstractAsyncMetricsDispatchTask; import org.springframework.beans.factory.annotation.Autowired; import java.util.ArrayList; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/BrokerHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/BrokerHealthCheckTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/BrokerHealthCheckTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/BrokerHealthCheckTask.java index ef02be8e..c8bdebaa 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/BrokerHealthCheckTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/BrokerHealthCheckTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.health; +package com.xiaojukeji.know.streaming.km.task.kafka.health; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.core.consensual.ConsensualEnum; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ClusterHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/ClusterHealthCheckTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ClusterHealthCheckTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/ClusterHealthCheckTask.java index 43c16cb8..0b5a2e18 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ClusterHealthCheckTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/ClusterHealthCheckTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.health; +package com.xiaojukeji.know.streaming.km.task.kafka.health; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.core.consensual.ConsensualEnum; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/GroupHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/GroupHealthCheckTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/GroupHealthCheckTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/GroupHealthCheckTask.java index d24f981d..5136d4dd 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/GroupHealthCheckTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/GroupHealthCheckTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.health; +package com.xiaojukeji.know.streaming.km.task.kafka.health; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.core.consensual.ConsensualEnum; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/TopicHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/TopicHealthCheckTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/TopicHealthCheckTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/TopicHealthCheckTask.java index 25a1e531..c3226feb 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/TopicHealthCheckTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/TopicHealthCheckTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.health; +package com.xiaojukeji.know.streaming.km.task.kafka.health; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.core.consensual.ConsensualEnum; 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/kafka/health/ZookeeperHealthCheckTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/ZookeeperHealthCheckTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/ZookeeperHealthCheckTask.java index 89a1c4f3..3eaea409 100644 --- 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/kafka/health/ZookeeperHealthCheckTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.health; +package com.xiaojukeji.know.streaming.km.task.kafka.health; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.core.consensual.ConsensualEnum; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/CommunityReassignJobTask.java similarity index 92% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/CommunityReassignJobTask.java index e655e57d..00dbd301 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/CommunityReassignJobTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.job; +package com.xiaojukeji.know.streaming.km.task.kafka.job; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; @@ -8,7 +8,7 @@ import com.didiglobal.logi.log.LogFactory; import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; import com.xiaojukeji.know.streaming.km.common.bean.entity.result.Result; import com.xiaojukeji.know.streaming.km.core.service.reassign.ReassignJobService; -import com.xiaojukeji.know.streaming.km.task.AbstractAsyncCommonDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.AbstractAsyncCommonDispatchTask; import org.springframework.beans.factory.annotation.Autowired; @Task(name = "CommunityReassignJobTask", diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/KMJobTask.java similarity index 86% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/KMJobTask.java index debb020c..9cf5e089 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/KMJobTask.java @@ -1,11 +1,11 @@ -package com.xiaojukeji.know.streaming.km.task.job; +package com.xiaojukeji.know.streaming.km.task.kafka.job; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.job.core.consensual.ConsensualEnum; import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; import com.xiaojukeji.know.streaming.km.core.service.job.JobService; -import com.xiaojukeji.know.streaming.km.task.AbstractAsyncCommonDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.AbstractAsyncCommonDispatchTask; import org.springframework.beans.factory.annotation.Autowired; @Task(name = "kmJobTask", diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/AbstractAsyncMetadataDispatchTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/AbstractAsyncMetadataDispatchTask.java similarity index 93% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/AbstractAsyncMetadataDispatchTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/AbstractAsyncMetadataDispatchTask.java index 668208c7..c2b8516d 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/AbstractAsyncMetadataDispatchTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/AbstractAsyncMetadataDispatchTask.java @@ -1,10 +1,10 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.log.ILog; import com.didiglobal.logi.log.LogFactory; import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; -import com.xiaojukeji.know.streaming.km.task.AbstractClusterPhyDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.AbstractClusterPhyDispatchTask; import com.xiaojukeji.know.streaming.km.task.service.TaskThreadPoolService; import org.springframework.beans.factory.annotation.Autowired; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerConfigDiffTask.java similarity index 98% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerConfigDiffTask.java index 04838b0f..42945c05 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerConfigDiffTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerTask.java similarity index 96% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerTask.java index a4d1dc99..c64b776f 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncControllerTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncControllerTask.java similarity index 96% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncControllerTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncControllerTask.java index 971ef852..ea0a7696 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncControllerTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncControllerTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaAclTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaAclTask.java similarity index 97% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaAclTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaAclTask.java index 8b87d36e..0dd5b8f7 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaAclTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaAclTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaGroupTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaGroupTask.java similarity index 98% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaGroupTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaGroupTask.java index cbec5bd2..b75ab3d9 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaGroupTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaGroupTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaUserTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaUserTask.java similarity index 96% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaUserTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaUserTask.java index 2e2fd63e..d3651abf 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncKafkaUserTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaUserTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncPartitionTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncPartitionTask.java similarity index 97% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncPartitionTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncPartitionTask.java index e4b07ec3..c0d50e09 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncPartitionTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncPartitionTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncTopicConfigTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicConfigTask.java similarity index 98% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncTopicConfigTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicConfigTask.java index 69b71d06..094f288c 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncTopicConfigTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicConfigTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncTopicTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicTask.java similarity index 96% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncTopicTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicTask.java index 4ed42c64..14b15a44 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncTopicTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncZookeeperTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncZookeeperTask.java similarity index 96% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncZookeeperTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncZookeeperTask.java index 5af37be2..e87f2bf1 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncZookeeperTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncZookeeperTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metadata; +package com.xiaojukeji.know.streaming.km.task.kafka.metadata; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/AbstractAsyncMetricsDispatchTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/AbstractAsyncMetricsDispatchTask.java similarity index 93% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/AbstractAsyncMetricsDispatchTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/AbstractAsyncMetricsDispatchTask.java index 705c2301..1907e279 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/AbstractAsyncMetricsDispatchTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/AbstractAsyncMetricsDispatchTask.java @@ -1,10 +1,10 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.common.TaskResult; import com.didiglobal.logi.log.ILog; import com.didiglobal.logi.log.LogFactory; import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; -import com.xiaojukeji.know.streaming.km.task.AbstractClusterPhyDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.AbstractClusterPhyDispatchTask; import com.xiaojukeji.know.streaming.km.task.service.TaskThreadPoolService; import org.springframework.beans.factory.annotation.Autowired; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/BrokerMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/BrokerMetricCollectorTask.java similarity index 95% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/BrokerMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/BrokerMetricCollectorTask.java index 58707aa2..09c004ad 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/BrokerMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/BrokerMetricCollectorTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ClusterMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ClusterMetricCollectorTask.java similarity index 95% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ClusterMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ClusterMetricCollectorTask.java index 6c489c72..f32f0588 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ClusterMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ClusterMetricCollectorTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/GroupMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/GroupMetricCollectorTask.java similarity index 95% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/GroupMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/GroupMetricCollectorTask.java index 7571236f..3018c211 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/GroupMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/GroupMetricCollectorTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/PartitionMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/PartitionMetricCollectorTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/PartitionMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/PartitionMetricCollectorTask.java index 0bc1dfbb..2a3c0a53 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/PartitionMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/PartitionMetricCollectorTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ReplicaMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ReplicaMetricCollectorTask.java similarity index 94% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ReplicaMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ReplicaMetricCollectorTask.java index e92a027f..80cc2644 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ReplicaMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ReplicaMetricCollectorTask.java @@ -1,4 +1,4 @@ -//package com.xiaojukeji.know.streaming.km.task.metrics; +//package com.xiaojukeji.know.streaming.km.task.kafka.metrics; // //import com.didiglobal.logi.job.annotation.Task; //import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/TopicMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/TopicMetricCollectorTask.java similarity index 95% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/TopicMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/TopicMetricCollectorTask.java index 18888452..3c1d023c 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/TopicMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/TopicMetricCollectorTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ZookeeperMetricCollectorTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java similarity index 95% rename from km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ZookeeperMetricCollectorTask.java rename to km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java index 2796f564..59aa86da 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metrics/ZookeeperMetricCollectorTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java @@ -1,4 +1,4 @@ -package com.xiaojukeji.know.streaming.km.task.metrics; +package com.xiaojukeji.know.streaming.km.task.kafka.metrics; import com.didiglobal.logi.job.annotation.Task; import com.didiglobal.logi.job.common.TaskResult; diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java index b0886754..d5512843 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java @@ -8,8 +8,8 @@ import com.xiaojukeji.know.streaming.km.common.component.SpringTool; import com.xiaojukeji.know.streaming.km.common.utils.BackoffUtils; import com.xiaojukeji.know.streaming.km.common.utils.FutureUtil; import com.xiaojukeji.know.streaming.km.persistence.cache.LoadedClusterPhyCache; -import com.xiaojukeji.know.streaming.km.task.metadata.AbstractAsyncMetadataDispatchTask; -import com.xiaojukeji.know.streaming.km.task.metrics.AbstractAsyncMetricsDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.metadata.AbstractAsyncMetadataDispatchTask; +import com.xiaojukeji.know.streaming.km.task.kafka.metrics.AbstractAsyncMetricsDispatchTask; import org.springframework.context.ApplicationListener; import org.springframework.stereotype.Service;