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");
     }