Spring Kafka监听器接收自定义对象时字段为null的排查求助

1. 配置代码存在语法错误 #

你的kafkaListenerContainerFactory方法有明显语法问题，导致ConsumerFactory实例无法正确创建：

• 变量声明错误：ConsumerFactory<String, MyObject> new DefaultKafkaConsumerFactory<>(...) 应改为 ConsumerFactory<String, MyObject> consumerFactory = new DefaultKafkaConsumerFactory<>(...)
• 构造函数调用末尾缺少分号
• 修正后的代码示例：

public ConcurrentKafkaListenerContainerFactory<String, MyObject> kafkaListenerContainerFactory() {
    ConsumerFactory<String, MyObject> consumerFactory = new DefaultKafkaConsumerFactory<>(props, 
        new StringDeserializer(), 
        new JsonDeserializer<>(MyObject.class));
    ConcurrentKafkaListenerContainerFactory<String, MyObject> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory);
    return factory;
}

2. JsonDeserializer 信任包未配置 #

默认情况下，JsonDeserializer仅信任org.springframework开头的包，若自定义的MyObject不在此范围内，需显式设置信任包，否则反序列化会被限制，生成空对象：

JsonDeserializer<MyObject> jsonDeserializer = new JsonDeserializer<>(MyObject.class);
jsonDeserializer.addTrustedPackages("com.your.package"); // 替换为MyObject实际所在的包路径

3. 生产者与消费者序列化逻辑不匹配 #

确保生产者发送消息时使用JsonSerializer，且未缺失类型信息头。若生产者未发送类型头，需在消费者的JsonDeserializer中配置默认类型：

jsonDeserializer.setDefaultType(MyObject.class);

4. 监听器注解使用错误 #

@KafkaHandler需配合类上的@KafkaListener使用，单独在方法上使用无法触发监听逻辑，应直接在方法上用@KafkaListener指定监听主题：

@KafkaListener(topics = "your_topic", groupId = "your_group_id")
public void listen(@Payload MyObject myobject) {
    // 业务处理逻辑
}

另外需检查MyObject类是否符合JavaBean规范：有无无参构造方法，字段是否配备对应的getter/setter方法，这是JSON反序列化的必要前提。

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