fix:kafka

zhuml4

2026-03-06 6474438cab58415f0ca8e8e333aad7d8c3ff4218

fix:kafka

 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();
    }
}