From 43f91540079303703f3d349a5e67ce219cdcaa8e Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Tue, 10 Jun 2025 17:24:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9mock?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai/analytic/center/controller/TestController.java     | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git 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
index 8a1f934..cf3451f 100644
--- 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");
     }