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 1b662cb..81e4b2f 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
@@ -53,7 +53,7 @@ public class TestController {
         try {
             AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
             log.info("mockKafka：{}",message);
-            for (int i = 0; i < 2; i++){
+            for (int i = 0; i < 10; i++){
                 aicorpusTelephone.setSourceId(aicorpusTelephone.getSourceId().concat("_"+i));
                 kafkaTemplate.send("topic_voc_covert_text_log", JSONObject.toJSONString(aicorpusTelephone)); // 发送 Kafka 消息
             }