[Feature]增加Truncate数据功能(didi#1043)

Author: duanxiaoqiu

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java

@@ -210,31 +210,11 @@ public Result<Void> expandTopic(TopicPartitionExpandParam expandParam, String op
     @Override
     public Result<Void> truncateTopic(TopicParam param, String operator) {
         try {
+            // 清空topic数据
             Result<Void> rv = (Result<Void>) doVCHandler(param.getClusterPhyId(), TOPIC_TRUNCATE, param);
-            if (rv.failed()) {
-                return rv;
-            }
-
-            // 删除DB中的Topic数据
-            topicService.deleteTopicInDB(param.getClusterPhyId(), param.getTopicName());
 
-            //解除高可用Topic关联
-            List<HaActiveStandbyRelation> haActiveStandbyRelations = haActiveStandbyRelationService.listByClusterAndType(param.getClusterPhyId(), HaResTypeEnum.MIRROR_TOPIC);
-            for (HaActiveStandbyRelation activeStandbyRelation : haActiveStandbyRelations) {
-                if (activeStandbyRelation.getResName().equals(param.getTopicName())) {
-                    try {
-                        KafkaZkClient kafkaZkClient = kafkaAdminZKClient.getClient(activeStandbyRelation.getStandbyClusterPhyId());
-                        Properties haTopics = kafkaZkClient.getEntityConfigs("ha-topics", activeStandbyRelation.getResName());
-                        if (haTopics.size() != 0) {
-                            kafkaZkClient.setOrCreateEntityConfigs("ha-topics", activeStandbyRelation.getResName(), new Properties());
-                            kafkaZkClient.createConfigChangeNotification("ha-topics/" + activeStandbyRelation.getResName());
-                        }
-                        haActiveStandbyRelationService.batchDeleteTopicHA(activeStandbyRelation.getActiveClusterPhyId(), activeStandbyRelation.getStandbyClusterPhyId(), Collections.singletonList(activeStandbyRelation.getResName()));
-                    } catch (Exception e) {
-                        log.error("method=truncateTopic||topicName:{}||errMsg=exception", activeStandbyRelation.getResName(), e);
-                        return Result.buildFailure(e.getMessage());
-                    }
-                }
+            if (rv == null || rv.failed()) {
+                return rv;
             }
 
             // 记录操作