diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java
index f47a3fa5..aa2bb7ec 100644
--- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java
+++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java
@@ -23,7 +23,6 @@ import com.xiaojukeji.know.streaming.km.common.utils.ConvertUtil;
 import com.xiaojukeji.know.streaming.km.core.service.broker.BrokerConfigService;
 import com.xiaojukeji.know.streaming.km.core.service.oprecord.OpLogWrapService;
 import com.xiaojukeji.know.streaming.km.core.service.version.BaseKafkaVersionControlService;
-import com.xiaojukeji.know.streaming.km.core.service.version.BaseVersionControlService;
 import com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminClient;
 import com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient;
 import com.xiaojukeji.know.streaming.km.persistence.mysql.broker.BrokerConfigDAO;
diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerSpecServiceImpl.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerSpecServiceImpl.java
index 5cbe3ce8..7ba20b15 100644
--- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerSpecServiceImpl.java
+++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerSpecServiceImpl.java
@@ -1,7 +1,5 @@
 package com.xiaojukeji.know.streaming.km.core.service.broker.impl;
 
-import com.didiglobal.logi.log.ILog;
-import com.didiglobal.logi.log.LogFactory;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.broker.BrokerSpec;
 import com.xiaojukeji.know.streaming.km.common.bean.po.config.PlatformClusterConfigPO;
 import com.xiaojukeji.know.streaming.km.common.enums.config.ConfigGroupEnum;
@@ -17,8 +15,6 @@ import java.util.Map;
 
 @Service
 public class BrokerSpecServiceImpl implements BrokerSpecService {
-    private static final ILog LOGGER = LogFactory.getLog(BrokerSpecServiceImpl.class);
-
     @Autowired
     private PlatformClusterConfigService platformClusterConfigService;
 
diff --git a/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java b/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java
index 8bac5ac6..f35c5ec6 100644
--- a/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java
+++ b/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java
@@ -16,11 +16,11 @@ import java.util.Map;
 import static com.xiaojukeji.know.streaming.km.monitor.common.MonitorSinkTagEnum.*;
 
 public abstract class AbstractMonitorSinkService implements ApplicationListener<BaseMetricEvent> {
-    protected static final ILog LOGGER = LogFactory.getLog(AbstractMonitorSinkService.class);
+    protected static final ILog LOGGER              = LogFactory.getLog(AbstractMonitorSinkService.class);
 
-    private static final int    STEP       = 60;
+    private static final int    STEP                = 60;
 
-    private FutureUtil<Void> sinkTP = FutureUtil.init(
+    private static final FutureUtil<Void> sinkTP    = FutureUtil.init(
             "SinkMetricsTP",
             5,
             5,
@@ -156,21 +156,6 @@ public abstract class AbstractMonitorSinkService implements ApplicationListener<
         return pointList;
     }
 
-    private List<MetricSinkPoint> replicationMetric2SinkPoint(List<ReplicationMetrics> replicationMetrics){
-        List<MetricSinkPoint> pointList = new ArrayList<>();
-
-        for(ReplicationMetrics r : replicationMetrics){
-            Map<String, Object> tagsMap = new HashMap<>();
-            tagsMap.put(CLUSTER_ID.getName(),     r.getClusterPhyId());
-            tagsMap.put(BROKER_ID.getName(),      r.getBrokerId());
-            tagsMap.put(PARTITION_ID.getName(),   r.getPartitionId());
-
-            pointList.addAll(genSinkPoint("Replication", r.getMetrics(), r.getTimestamp(), tagsMap));
-        }
-
-        return pointList;
-    }
-
     private List<MetricSinkPoint> zookeeperMetric2SinkPoint(List<ZookeeperMetrics> zookeeperMetricsList){
         List<MetricSinkPoint> pointList = new ArrayList<>();
 
diff --git a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java
index 32ac7ce8..cb67b14b 100644
--- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java
+++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java
@@ -39,6 +39,7 @@ public class DataBaseDataLocalCache {
     private static Cache<Long, Map<String, List<Partition>>> partitionsCache;
 
     private static Cache<Long, Map<String, List<HealthCheckResultPO>>> healthCheckResultCache;
+
     private static Cache<String, Boolean> haTopicCache;
 
     @PostConstruct