tijiao

simulation-resource-server/src/main/java/com/css/simulation/resource/server/app/impl/MultiSimulationProjectServiceImpl.java

@@ -239,15 +239,15 @@ public class MultiSimulationProjectServiceImpl implements MultiSimulationProject
 
     // TODO 测试时候打开
     public void sendKafka(KafkaParameter kafkaParameter){
-//        kafkaTemplate.send(kafkaParameter.getTopic(), kafkaParameter.getData()).addCallback(success -> {
-//            // 消息发送到的topic
-//            String topic = success.getRecordMetadata().topic();
-//            // 消息发送到的分区
-//            int partition = success.getRecordMetadata().partition();
-//            // 消息在分区内的offset
-//            long offset = success.getRecordMetadata().offset();
-//            log.info("停止任务发送消息成功，主题 topic 为：" + topic + "，分区 partition 为：" + partition + "，偏移量为：" + offset + "，消息体为：" + kafkaParameter.getData());
-//        }, failure -> log.error("发送消息失败:" + failure.getMessage()));
+        kafkaTemplate.send(kafkaParameter.getTopic(), kafkaParameter.getData()).addCallback(success -> {
+            // 消息发送到的topic
+            String topic = success.getRecordMetadata().topic();
+            // 消息发送到的分区
+            int partition = success.getRecordMetadata().partition();
+            // 消息在分区内的offset
+            long offset = success.getRecordMetadata().offset();
+            log.info("停止任务发送消息成功，主题 topic 为：" + topic + "，分区 partition 为：" + partition + "，偏移量为：" + offset + "，消息体为：" + kafkaParameter.getData());
+        }, failure -> log.error("发送消息失败:" + failure.getMessage()));
     }
 
     public ResponseBodyVO<MultiSimulationProjectVO> submitMultiSimulationProjectDetail(MultiSimulationProjectParam param){