tijiao

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

@@ -341,7 +341,6 @@ public class ProjectApplicationService {
 
     }
 
-
     /**
      * 任务运行前首先判断用户是否拥有可分配资源
      *
@@ -582,8 +581,11 @@ public class ProjectApplicationService {
             MultiTaskMessageEntity messageEntity = multiTaskMessageEntityList.get(i);
             String taskId = messageEntity.getInfo().getTask_id();
             // 发送kafka消息
+//            SendResult<String, String> stringStringSendResult = kafkaTemplate.send(projectId, i % multiTaskMessageEntityList.size(),
+//                taskId, JSONObject.toJSONString(messageEntity)).get();
             SendResult<String, String> stringStringSendResult = kafkaTemplate.send(projectId, i % multiTaskMessageEntityList.size(),
-                taskId, JSONObject.toJSONString(messageEntity)).get();
+                taskId, JsonUtil.beanToJson(messageEntity)).get();
+
             RecordMetadata recordMetadata = stringStringSendResult.getRecordMetadata();
             String topic = recordMetadata.topic();  // 消息发送到的topic
             int partition = recordMetadata.partition(); // 消息发送到的分区