修改kafka消费

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java

@@ -52,7 +52,7 @@ public class TestController {
     public ResultMsg<Object> mockKafka(@RequestBody String message) {
         try {
             AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
-            for (int i = 0; i < 100000; i++){
+            for (int i = 0; i < 10; i++){
                 aicorpusTelephone.setSourceId(aicorpusTelephone.getSourceId().concat("_"+i));
                 kafkaTemplate.send(kafkaTopic, JSONObject.toJSONString(aicorpusTelephone)); // 发送 Kafka 消息
             }