提交 48913c75 编写于 作者: 金永显's avatar 金永显

添加相关完成注解

上级 c9f4852f
......@@ -25,5 +25,6 @@ public class SinanKzProcurementTaskResultTestKafkaService {
public void topicResult(ConsumerRecord<String, Object> consumerRecord){
log.info("返回审核结果消息:{}", consumerRecord.value());
kafkaTestTemplate.send(topicResult,consumerRecord.toString());
log.info("审核结果:{}", "转发测试服务器成功");
}
}
......@@ -32,6 +32,7 @@ public class SinanKzProcurementTaskTestKafkaService {
public void topicProducerSim(ConsumerRecord<String, Object> consumerRecord){
log.info("任务生成消息接收:{}", consumerRecord.value());
kafkaLianjiaTemplate.send(topicProducer,consumerRecord.toString());
log.info("任务生成消息接收:{}","发送司南工单成功!!");
}
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册