如何通过SpEL配置Spring Kafka的RecordFilterStrategy并解决空指针问题

问题场景 #

从spring-kafka 2.8.4版本起，@KafkaListener新增filter属性，支持通过指定RecordFilterStrategy Bean或SpEL表达式过滤入站消息。RecordFilterStrategy的filter方法返回true时，对应消息会被丢弃。

用户原本通过Bean实现的过滤逻辑如下：

@Bean
public RecordFilterStrategy<String, Foo> recordFilterStrategy() {
    return rec -> !Objects.equals(rec.key(), EventType.CREATE.toString());
}

尝试用SpEL表达式#{#consumerRecord.key().equals(T(com.example.kafkaconsumer.EventType).CREATE.toString())}替代时，触发SpelEvaluationException：EL1011E: 尝试在空上下文对象上调用key()方法，核心问题是未正确引用上下文里的消息对象。

正确实现方式 #

在@KafkaListener的filter属性的SpEL上下文中，当前消息实例的引用变量是#record，而非#consumerRecord。

所以正确的SpEL表达式应为：

#{!#record.key().equals(T(com.example.kafkaconsumer.EventType).CREATE.toString())}

也可以简化为更简洁的写法：

#{#record.key != T(com.example.kafkaconsumer.EventType).CREATE.toString()}

注意点 #

• 表达式返回结果需与原Bean逻辑一致：当消息key不等于EventType.CREATE.toString()时返回true，对应消息被丢弃；反之保留
• 确保EventType的全限定类名在SpEL中正确引用，避免类找不到的问题

内容的提问来源于stack exchange，提问作者Vitaly Chura