修改mock

2025-06-10 17:24:27 +08:00
parent 857879b6e7
commit 43f9154007
1 changed files with 2 additions and 6 deletions
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
@@ -72,12 +72,8 @@ public class TestController {
    @ApiOperation(value = "补偿处理消息")
    public ResultMsg<Object> mockDccKafka(@RequestBody AicorpusTelephoneDTO message) {

-       for(int i=0;i<20;i++){
-           String sourceId = "2000000"+i;
-           message.setSourceId(sourceId);
-           log.info("发送消息："+sourceId);
-           dccKafkaProducer.send("topic_voc_covert_text_log",JSONObject.toJSONString(message));
-       }
+       dccKafkaProducer.send("topic_voc_covert_text_log",JSONObject.toJSONString(message));
+
        return ResultMsg.ok("ok");
    }