admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改kafka消费

Browse Source
This commit is contained in:
zren25
2025-03-31 13:30:02 +08:00
parent 54acdc968d
commit c9371875d5
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -52,9 +52,10 @@ public class TestController {
public ResultMsg<Object> mockKafka(@RequestBody String message) { public ResultMsg<Object> mockKafka(@RequestBody String message) {
try { try {
AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class); AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
for (int i = 0; i < 10; i++){ log.info("mockKafka：{}",message);
for (int i = 0; i < 2; i++){
aicorpusTelephone.setSourceId(aicorpusTelephone.getSourceId().concat("_"+i)); aicorpusTelephone.setSourceId(aicorpusTelephone.getSourceId().concat("_"+i));
kafkaTemplate.send(kafkaTopic, JSONObject.toJSONString(aicorpusTelephone)); // 发送 Kafka 消息 kafkaTemplate.send("topic_voc_covert_text_log", JSONObject.toJSONString(aicorpusTelephone)); // 发送 Kafka 消息
} }
log.info("Kafka 消息已发送: {}", message); log.info("Kafka 消息已发送: {}", message);
} catch (JsonProcessingException e) { } catch (JsonProcessingException e) {