Spring Kafka设置MANUAL_IMMEDIATE手动提交调用acknowledge报空指针异常

这个空指针异常绝大多数场景是你调用acknowledge()方法时，Acknowledgment对象本身未被Spring正确注入、值为null导致的，常见触发原因如下：

• 监听器工厂配置错误：虽然设置了MANUAL_IMMEDIATE提交模式，但ConcurrentKafkaListenerContainerFactory未正确配置AckMode，或批量消费场景下未开启setBatchListener(true)，Spring无法识别需要注入Acknowledgment参数。
• 监听器方法参数不合法：@KafkaListener注解的方法中，Acknowledgment参数添加了无关注解、位置错误，或未指定正确的containerFactory，导致参数注入失败。
• 异步调用场景异常：将Acknowledgment对象传递到监听器方法外的异步线程调用，消费线程执行完成后Spring已释放Acknowledgment对象引用，再次调用会触发空指针。
• 版本不兼容：你使用的2.2.5.RELEASE版本Spring Kafka仅适配Spring Boot 2.1.x系列，若Spring Boot版本高于2.2.x会出现配置兼容问题，导致参数注入失败。

• 第一步先定位空指针来源：在调用ack.acknowledge()前添加日志打印ack对象是否为null，排除业务代码中其他对象空指针的可能性。
• 第二步校验监听器工厂配置，确保配置完整正确，参考配置如下：

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory(ConsumerFactory<String, String> consumerFactory) {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory);
    // 批量消费必须开启该配置，匹配你方法的List<ConsumerRecord>参数
    factory.setBatchListener(true);
    // 明确设置手动立即提交模式
    factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE);
    // 关闭自动提交，和配置文件中spring.kafka.consumer.enable-auto-commit=false保持一致
    factory.getContainerProperties().setSyncCommits(true);
    return factory;
}

• 第三步检查@KafkaListener方法写法，确保参数无多余注解、指定正确的工厂：

// 正确写法示例
@KafkaListener(topics = "你的业务topic", containerFactory = "kafkaListenerContainerFactory")
public void consumerBatch(List<ConsumerRecord<String, String>> records, Acknowledgment ack) {
    // 执行业务逻辑
    // 直接在当前线程调用ack
    ack.acknowledge();
}

不要给Acknowledgment参数添加@Nullable、@RequestParam等无关注解，不要调整参数顺序到ConsumerRecord列表之前。

• 第四步排查异步调用场景：如果之前是在异步线程调用ack，先改到监听器方法的当前线程调用测试，若不再报错则说明是异步场景下对象提前释放导致，可调整逻辑保证ack调用在消费方法执行完成前完成，或开启Spring Kafka的异步ack支持配置。
• 第五步校验版本兼容：如果Spring Boot版本高于2.1.x，可将Spring Kafka版本升级到2.3.x以上的兼容版本，避免版本适配问题。

内容的提问来源于stack exchange，提问作者Alfred-Ning