mlx

simulation-resource-scheduler/pom.xml

@@ -110,6 +110,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-validation</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/consumer/ProjectConsumer.java

@@ -34,7 +34,8 @@ public class ProjectConsumer {
     public void parseProject(ConsumerRecord<String, String> projectRecord) throws JsonProcessingException, JSONException {
         //1 读取 kafka 的 project 信息
         String projectJson = projectRecord.value();
-        JSONObject projectJsonObject = JsonUtil.jsonToJSONObject(projectJson);
+
+        JSONObject projectJsonObject = new JSONObject(projectJson);
         String projectId = projectJsonObject.optString("projectId");        // 项目 id
         String defaultTime = projectJsonObject.optString("defaultTime");    // 任务执行时间，一个工作里的所有任务公用
         String parallelism = projectJsonObject.optString("parallelism");    // 并行度，创建 pod 时使用