Sarama客户端心跳正常但长时间不消费是否触发重平衡？

核心结论 #

不会触发重平衡

配置差异对比 #

Java Kafka消费者有两个关键的消费组存活控制配置：

• session.timeout.ms：心跳超时阈值，若broker超过该时间未收到客户端心跳，会判定客户端离线并触发重平衡
• max.poll.interval.ms：两次poll()调用的最大间隔，若超过该阈值，客户端会主动发送LeaveGroupRequest退出消费组，进而触发重平衡

而在Sarama（v1.38.1）中：

• 仅提供Consumer.Group.Session.Timeout配置，对应Java的session.timeout.ms，负责心跳超时的判定
• 没有直接对应max.poll.interval.ms的配置，不存在“因长时间不调用poll而主动退组”的逻辑

代码行为分析 #

从你贴出的brokerConsumer.subscriptionConsumer()代码片段可以看到：
当客户端长时间不消费消息时，fetchNewMessages()会进入循环尝试拉取消息，但即使没有消息可处理，也不会触发LeaveGroupRequest发送。只要心跳goroutine持续运行，broker就能收到正常的心跳包，会判定该客户端处于存活状态，不会触发重平衡流程。

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