From 6474438cab58415f0ca8e8e333aad7d8c3ff4218 Mon Sep 17 00:00:00 2001
From: zhuml4 <zhuml4@xiaopeng.com>
Date: 星期六, 07 三月 2026 21:01:36 +0800
Subject: [PATCH] fix:kafka
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java | 12 ++++++++++++
1 files changed, 12 insertions(+), 0 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 279020b..2c776c7 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
@@ -42,4 +42,16 @@
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