Spring Kafka中RecordInterceptor多拦截方法问题：需实现已弃用方法

为什么必须实现已弃用的单参数intercept方法？ #

这是因为你使用的Spring Kafka版本中，RecordInterceptor接口的单参数intercept方法仍然是抽象方法（而非默认方法）。根据Java语法规则，实现接口时必须重写所有未提供默认实现的抽象方法——哪怕该方法被标记为@Deprecated。

在后续更新的Spring Kafka版本中，官方将单参数intercept方法修改为了默认方法，其内部会调用双参数版本的方法，此时就不再强制要求开发者实现这个弃用方法了。

为什么双参数intercept方法不会被调用？ #

原因在于你当前使用的Spring Kafka版本的底层调用逻辑，仍然只触发单参数的intercept方法。双参数版本是后续版本新增的扩展方法，框架还未切换到以它作为主要的拦截入口。而接口中默认的双参数方法只是简单调用单参数方法，所以即使你重写了它，只要框架没主动调用双参数方法，你的实现代码就不会执行。

解决办法 #

1. 升级Spring Kafka版本：升级到足够新的版本（如2.7.x及以上），此时框架会优先调用双参数intercept方法，单参数方法变为默认实现，无需强制重写。
2. 兼容旧版本的写法：在重写单参数方法时，主动调用你自定义的双参数方法，示例代码如下：

@Override
@Nullable
public ConsumerRecord<K, V> intercept(ConsumerRecord<K, V> record) {
    // 主动调用双参数方法，若框架无法传入Consumer，可传null并在方法内做兼容处理
    return this.intercept(record, null);
}

@Override
@Nullable
public ConsumerRecord<K, V> intercept(ConsumerRecord<K, V> record, Consumer<K, V> consumer) {
    // 这里编写你的拦截逻辑
    return record;
}

内容的提问来源于stack exchange，提问作者Steven Kristian