package com.xiaopeng.automaticPilot.service;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.kafka.annotation.KafkaListener;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* Kafka 消费者服务
|
*/
|
@Slf4j
|
@Service
|
public class KafkaConsumerService {
|
|
/**
|
* 消费消息 - XPU上报Robotaxi云端的消息topic（高优先级）
|
*
|
* @param message 消息内容
|
*/
|
@KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
|
public void consumeAutomaticPilotMessage(String message) {
|
try {
|
log.info("收到XPU上报高优先级主题消息: {}", message);
|
} catch (Exception e) {
|
log.error("处理XPU上报高优先级主题消息失败: {}", message, e);
|
throw e;
|
}
|
}
|
|
/**
|
* 消费消息 - XPU上报Robotaxi云端的消息topic（低优先级）
|
*
|
* @param message 消息内容
|
*/
|
@KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
|
public void consumeVehicleStatusMessage(String message) {
|
try {
|
log.info("收到XPU上报低优先级主题消息: {}", message);
|
|
} catch (Exception e) {
|
log.error("处理XPU上报低优先级主题消息失败: {}", message, e);
|
throw e;
|
}
|
}
|
|
|
}
|
