tijiao

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/app/service/ProjectApplicationService.java

@@ -1109,6 +1109,7 @@ public class ProjectApplicationService {
             // 首先删掉历史的projectId记录
             taskRecordMapper.deleteProjectByProjectId(projectId);
             resultMapper.deleteProjectResultByProjectId(projectId);
+            KafkaUtil.deleteTopic(kafkaAdminClient, projectId);
 
             List<MultiSimulationSceneKafkaParam> kafkaParamList = projectStartMessageEntity.getKafkaParamList();
             List<MultiTaskMessageEntity> entityList = new ArrayList<>();
@@ -1226,6 +1227,7 @@ public class ProjectApplicationService {
             return build;
         } catch (Exception e) {
             log.error("项目报错。", e);
+            // TODO 项目报错之后状态设置一下
             throw new RuntimeException(e);
         }
     }