如何通过SpEL在@KafkaListener中注入自定义Kafka反序列化器？

直接在@KafkaListener的properties中使用SpEL表达式#{@customMessageDeserializer}引用Spring容器中的反序列化器Bean，即可解决反射创建实例导致的无参构造缺失、ObjectMapper空指针问题。

修改后的@KafkaListener配置 #

@KafkaListener(
    topics = {"${topics.invite-user-topic}"},
    properties = {"value.deserializer=#{@customMessageDeserializer}"}
)
public void receiveInviteUserMessages(MyMessage myMessage) {}

关键说明 #

• #{@beanName}是Spring SpEL的标准语法，用于直接获取容器中的Bean实例：
  • 示例中的customMessageDeserializer是Spring默认生成的Bean名称（类名首字母小写），如果你的CustomMessageDeserializer通过@Component("自定义名称")指定了Bean名，替换为对应的名称即可。
• 该方式下，Kafka Spring集成会直接复用容器中已注入ObjectMapper的反序列化器实例，不会再通过反射创建新对象，从根源避免了无参构造报错和空指针异常。

额外验证点 #

确认CustomMessageDeserializer所在包已被Spring的@ComponentScan覆盖，确保Bean已被成功纳入容器管理，否则SpEL会找不到对应实例。

内容的提问来源于stack exchange，提问作者Sambalinski Johnny