添加模拟XPU推送消息接口

puzhibing

2026-03-06 bdb5ea4433f77c531912e7b4c2093bbff34abac5

添加模拟XPU推送消息接口

 xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java

@@ -42,19 +42,4 @@
        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();
    }


}