算法平台算法暂时手动删除

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/manager/TaskManager.java

@@ -58,6 +58,15 @@ public class TaskManager {
     String evaluationLevelUri;
     @Value("${scheduler.minio-path.project-result}")
     String resultPathMinio;
+
+    @Value("${spring.kafka.hostname}")
+    String hostnameKafka;
+    @Value("${spring.kafka.username}")
+    String usernameKafka;
+    @Value("${spring.kafka.password}")
+    String passwordKafka;
+    @Value("${spring.kafka.delete-command}")
+    String kafkaDeleteCommand;
     @Resource
     StringRedisTemplate stringRedisTemplate;
     @Resource
@@ -436,11 +445,11 @@ public class TaskManager {
 
 
         // 删除 kafka topic
-//        SshClient clientKafka = SshUtil.getClient();
-//        ClientSession sessionKafka = SshUtil.getSession(clientKafka, hostnameKafka, usernameKafka, passwordKafka);
-//        String topicDeleteCommand = StringUtil.replace(kafkaDeleteCommand, "topicName", projectId);
-//        SshUtil.execute(sessionKafka, topicDeleteCommand);
-//        SshUtil.stop(clientKafka, sessionKafka);
+        SshClient clientKafka = SshUtil.getClient();
+        ClientSession sessionKafka = SshUtil.getSession(clientKafka, hostnameKafka, usernameKafka, passwordKafka);
+        String topicDeleteCommand = StringUtil.replace(kafkaDeleteCommand, "topicName", projectId);
+        SshUtil.execute(sessionKafka, topicDeleteCommand);
+        SshUtil.stop(clientKafka, sessionKafka);
 
 
         // 归还并行度