From 13ddb6d5122010bd7b465b157b375cb53b8b8a7d Mon Sep 17 00:00:00 2001
From: zhuml4 <zhuml4@xiaopeng.com>
Date: 星期六, 07 三月 2026 21:01:25 +0800
Subject: [PATCH] fix:去掉没用注释
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
index 7acf847..327ea18 100644
--- a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
+++ b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
@@ -3,6 +3,7 @@
import com.xiaopeng.automaticPilot.service.KafkaConsumerService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
@@ -21,8 +22,7 @@
*
* @param message 消息内容
*/
-// @KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
- @PostMapping("/test/kafka/xpu-high")
+ @KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
public void topicProdRobotaxiXpuHigh(@RequestBody String message) {
log.info("收到XPU上报高优先级主题消息: {}", message);
kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
@@ -35,8 +35,7 @@
*
* @param message 消息内容
*/
-// @KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
- @PostMapping("/test/kafka/xpu-normal")
+ @KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
public void topicProdRobotaxiXpuNormal(String message) {
log.info("收到XPU上报低优先级主题消息: {}", message);
kafkaConsumerService.topicProdRobotaxiXpuNormal(message);
--
Gitblit v1.7.1