• 可能原因

可能是Kafka客户端版本过低或者Consumer没有独立线程维持心跳。

v0.10.2之前版本的客户端：Consumer没有独立线程维持心跳，而是把心跳维持与poll接口耦合在一起。其结果就是，如果用户消费出现卡顿，就会导致Consumer心跳超时，引发Rebalance。

v0.10.2及之后版本的客户端：如果消费时间过慢，超过一定时间（max.poll.interval.ms设置的值，默认5分钟）未进行poll拉取消息，则会导致客户端主动离开队列，而引发Rebalance。

• 解决方案

首先您需要了解以下几点信息：

session.timeout.ms：心跳超时时间（可以由客户端自行设置）。

max.poll.records：每次poll返回的最大消息数量。

v0.10.2之前版本的客户端：心跳是通过poll接口来实现的，没有内置的独立线程。

v0.10.2及之后版本的客户端：为了防止客户端长时间不进行消费，Kafka客户端在v0.10.2及之后的版本中引入了max.poll.interval.ms配置参数。

（1）参考以下说明调整参数值：

session.timeout.ms：v0.10.2之前的版本可适当提高该参数值，需要大于消费一批数据的时间，但不要超过30s，建议设置为25s；而v0.10.2及其之后的版本，保持默认值10s即可。

max.poll.records：降低该参数值，建议远远小于<单个线程每秒消费的条数> * <消费线程的个数> *的积。

max.poll.interval.ms：该值要大于 / (<单个线程每秒消费的条数> * <消费线程的个数>)的值。

（2）尽量提高客户端的消费速度，消费逻辑另起线程进行处理。

（3）减少Group订阅Topic的数量，一个Group订阅的Topic最好不要超过5个，建议一个Group只订阅一个Topic。

（4）将客户端升级至0.10.2以上版本。