From d01f99eafc417c56c20d2cf34564d2dd3b12cb91 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期六, 07 三月 2026 21:01:45 +0800
Subject: [PATCH] 同步最新代码
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java | 14 --------------
1 files changed, 0 insertions(+), 14 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 2c776c7..d22d0a8 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
@@ -24,7 +24,6 @@
*
* @param message 消息内容
*/
- @PostMapping("/test/kafka/xpu-high")
@KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
public void topicProdRobotaxiXpuHigh(String message) {
log.info("收到XPU上报高优先级主题消息: {}", message);
@@ -36,22 +35,9 @@
*
* @param message 消息内容
*/
- @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);
- }
-
- /**
- * 模拟推送XPU消息
- * @param message
- * @return
- */
- @PostMapping("/base/v1/pushXPUMessage")
- public R pushXPUMessage(String message) {
- log.info("收到XPU推送消息: {}", message);
- kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
- return R.ok();
}
}
--
Gitblit v1.7.1