如何正确处理InvalidPidMappingException？捕获位置选择指南

算力阿峰

2026-8-5

如何正确处理InvalidPidMappingException异常

核心判断依据：异常的触发场景与影响范围

如果异常是业务逻辑执行中触发的（比如消息体解析PID映射失败、业务规则校验PID不合法）：
应该在业务流程处理逻辑中捕获。
原因：这类异常属于业务层面的错误，业务逻辑本身更清楚如何处理——比如记录详细业务日志、标记消息处理失败、触发死信队列投递等针对性操作。
示例代码（伪代码）：

public void processKafkaMessage(Message msg) {
    try {
        // 业务逻辑：解析PID映射
        PidMapping mapping = parsePidMapping(msg.getPayload());
        // 后续业务操作
        handleBusinessLogic(mapping);
    } catch (InvalidPidMappingException e) {
        log.error("业务处理失败：PID映射无效，消息ID: {}", msg.getId(), e);
        sendToDeadLetterQueue(msg, e.getMessage());
    }
}

如果异常是Kafka客户端/框架层面触发的（比如消费消息时框架内部的PID映射校验失败，与业务逻辑无关）：
应该在Kafka错误处理器内部捕获。
原因：这类异常属于框架层面的技术错误，业务逻辑无需感知，错误处理器可以统一处理——比如触发消费重试、记录技术日志、发送告警通知。
示例代码（伪代码）：

public class KafkaErrorHandler implements ErrorHandler {
    @Override
    public void handle(Exception thrownException, ConsumerRecord<?, ?> record) {
        if (thrownException instanceof InvalidPidMappingException) {
            log.error("Kafka消费框架错误：PID映射无效，topic: {}, offset: {}", record.topic(), record.offset(), thrownException);
            triggerRetry(record);
            sendAlert("Kafka消费PID映射异常");
        } else {
            handleOtherExceptions(thrownException, record);
        }
    }
}