From 1d8fa38794d80659dd263085198fd0e0f9a2cec7 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期五, 13 二月 2026 21:23:41 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java | 29 ++++++-----------------------
1 files changed, 6 insertions(+), 23 deletions(-)
diff --git a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
index 5cd28b5..fcdccc9 100644
--- a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
+++ b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
@@ -1,21 +1,14 @@
package com.xiaopeng.automaticPilot.controller;
-import com.alibaba.fastjson2.JSON;
-import com.xiaopeng.api.vo.automaticPilot.proto.up.MsgContent;
import com.xiaopeng.automaticPilot.service.KafkaConsumerService;
-import io.swagger.annotations.Api;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.RestController;
-/**
- * Kafka 测试控制器
- */
+
@Slf4j
@RestController
-@RequestMapping("/kafka")
-@Api(tags = "Kafka 测试接口")
public class KafkaTestController {
@Autowired
@@ -31,13 +24,8 @@
*/
@KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
public void topicProdRobotaxiXpuHigh(String message) {
- try {
- log.info("收到XPU上报高优先级主题消息: {}", message);
- kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
- } catch (Exception e) {
- log.error("处理XPU上报高优先级主题消息失败: {}", message, e);
- throw e;
- }
+ log.info("收到XPU上报高优先级主题消息: {}", message);
+ kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
}
/**
@@ -47,12 +35,7 @@
*/
@KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
public void topicProdRobotaxiXpuNormal(String message) {
- try {
- log.info("收到XPU上报低优先级主题消息: {}", message);
- kafkaConsumerService.topicProdRobotaxiXpuNormal(message);
- } catch (Exception e) {
- log.error("处理XPU上报低优先级主题消息失败: {}", message, e);
- throw e;
- }
+ log.info("收到XPU上报低优先级主题消息: {}", message);
+ kafkaConsumerService.topicProdRobotaxiXpuNormal(message);
}
}
--
Gitblit v1.7.1