Spring Kafka AggregatingReplyingKafkaTemplate默认超时时间修改无效问题

你设置的setDefaultReplyTimeout是发送端等待回复的超时时间，但实际遇到的30-40秒超时是消费端Listener处理消息的超时限制，这是两个独立的配置项，需要分别调整。

1. 确保发送端等待回复超时生效 #

你当前调用的sendAndReceive(ProducerRecord)会使用默认超时配置，这部分是正常的。如果后续需要为单条请求单独设置超时，可使用重载方法：

return this.aggregatingReplyingKafkaTemplate.sendAndReceive(producerRecord, Duration.ofSeconds(600));

2. 调整消费端Listener的超时限制 #

消费端的超时由以下核心配置控制，需针对性修改：

（1）@KafkaListener的timeout属性 #

如果回复端的Listener注解里设置了timeout，会直接限制单条消息的处理时长，比如：

@KafkaListener(topics = "reply-topic", timeout = "30000") // 30秒超时

需将该值修改为10分钟（600000毫秒），或直接移除该属性，让容器使用全局配置。

（2）消费者容器的max.poll.interval.ms #

这是Kafka消费者的核心参数，控制两次poll操作的最大间隔时间，超过该值broker会判定消费者异常并将其踢出消费组，导致消息处理中断。需将其设置为大于10分钟的值：

// 配置回复消费者容器工厂
ConcurrentKafkaListenerContainerFactory<String, R> replyContainerFactory = new ConcurrentKafkaListenerContainerFactory<>();
// 设置容器poll超时（建议与max.poll.interval匹配）
replyContainerFactory.getContainerProperties().setPollTimeout(600000);
// 设置消费者核心属性
Map<String, Object> consumerProps = new HashMap<>();
consumerProps.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 600000); // 10分钟
consumerProps.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 30000); // 心跳超时，按需调整
replyContainerFactory.setConsumerFactory(new DefaultKafkaConsumerFactory<>(consumerProps));

如果回复容器是通过AggregatingReplyingKafkaTemplate构造时传入的，确保使用的容器工厂已配置上述参数。

（3）集群配置检查 #

确认Kafka集群的group.max.session.timeout.ms值，确保你设置的session.timeout.ms不超过集群允许的最大值，否则会被集群强制覆盖。

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