From a62750f5a64e6cab5682c28323afe301cea00234 Mon Sep 17 00:00:00 2001 From: zren25 Date: Mon, 31 Mar 2025 14:20:28 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9mock=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/volvo/ai/analytic/center/controller/TestController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 消息 }