Spring Kafka如何实现基于细粒度条件的不可重试异常过滤？

你遇到的这个问题其实挺常见的——Spring Kafka默认的DefaultErrorHandler确实只提供了按异常类来标记不可重试的API，没有直接的addNotRetryableExceptionFilter这类方法，但我们可以通过两种灵活的方式来实现这种细粒度的判断逻辑，下面给你详细说明：

方案一：自定义BinaryExceptionClassifier #

DefaultErrorHandler内部是通过BinaryExceptionClassifier来区分「可重试」和「不可重试（致命）」异常的，我们可以自定义这个分类器的逻辑，既保留原有按类过滤的规则，又添加自己的细粒度判断。

首先创建带有自定义逻辑的分类器：

// 初始化时传入原本需要标记为不可重试的异常类
BinaryExceptionClassifier customClassifier = new BinaryExceptionClassifier(Collections.singleton(NotRetryableException.class)) {
    @Override
    public boolean isFatal(Throwable throwable) {
        // 先执行父类的判断逻辑，处理按类过滤的情况
        boolean isFatalByClass = super.isFatal(throwable);
        if (isFatalByClass) {
            return true;
        }
        // 添加自己的细粒度判断：如果异常消息以"foo"开头，也标记为不可重试
        if (throwable.getMessage() != null && throwable.getMessage().startsWith("foo")) {
            return true;
        }
        // 其他情况都视为可重试
        return false;
    }
};

然后将这个自定义分类器绑定到DefaultErrorHandler上：

DefaultErrorHandler errorHandler = new DefaultErrorHandler(
    (consumerRecord, e) -> {
        log.error("Exception happened for {}", consumerRecord, e);
    },
    exponentialBackOff
);
// 替换默认的分类器
errorHandler.setClassifier(customClassifier);

方案二：直接扩展DefaultErrorHandler，重写isRetryable方法 #

如果你觉得自定义分类器有点绕，也可以直接继承DefaultErrorHandler，重写它的isRetryable方法，在原有逻辑基础上加入自己的判断规则。

示例代码如下：

DefaultErrorHandler customErrorHandler = new DefaultErrorHandler(
    (consumerRecord, e) -> {
        log.error("Exception happened for {}", consumerRecord, e);
    },
    exponentialBackOff
) {
    @Override
    protected boolean isRetryable(Exception exception) {
        // 先调用父类的逻辑，处理已添加的不可重试异常类
        boolean isRetryableByDefault = super.isRetryable(exception);
        if (!isRetryableByDefault) {
            return false;
        }
        // 自定义判断：如果异常消息以"foo"开头，就不允许重试
        if (exception.getMessage() != null && exception.getMessage().startsWith("foo")) {
            return false;
        }
        // 其他情况允许重试
        return true;
    }
};

// 原来按类添加不可重试异常的代码依然有效
customErrorHandler.addNotRetryableExceptions(NotRetryableException.class);

这两种方案都能满足你的需求：方案一更贴合Spring Kafka的原有设计，把异常分类逻辑集中管理；方案二更直接直观，适合快速定制重试判断规则。你可以根据自己的代码风格和需求来选择。

备注：内容来源于stack exchange，提问作者Petro Prydorozhnyi