Spring升级后Kafka pollTimeout默认值变更疑问及相关版本咨询

• 确实存在默认pollTimeout为500ms的版本：你之前使用的Spring Boot 2.3.12.RELEASE对应的Spring Kafka版本是2.5.x，这个版本的ConcurrentKafkaListenerContainerFactory默认pollTimeout就是500ms。
• 版本升级后的变化：Spring Boot 2.7.5适配的Spring Kafka版本是2.8.x，从Spring Kafka 2.6.x开始，官方将pollTimeout的默认值调整为了5000ms，这就是你观察到行为差异的原因。

验证与恢复思路 #

• 源码验证：直接查看对应版本的Spring Kafka源码，2.5.x的ConcurrentKafkaListenerContainerFactory构造方法中会默认设置pollTimeout = 500，而2.6.x及以后版本默认值为5000。
• 恢复原有行为：在容器工厂中显式指定pollTimeout为500ms即可，示例代码如下：

@Bean
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(
        ConsumerFactory<Object, Object> consumerFactory) {
    ConcurrentKafkaListenerContainerFactory<Object, Object> factory =
            new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory);
    factory.getContainerProperties().setPollTimeout(500); // 手动设置为500ms
    return factory;
}

注意事项 #

• 官方文档通常只展示当前稳定版的默认配置，旧版本的默认值需要查阅对应版本的文档或源码。
• 框架升级时，建议同步关注依赖组件（如Spring Kafka）的版本变更日志，重点留意核心配置项的默认值调整。

内容的提问来源于stack exchange，提问作者Gabriel Gomes Crispim