要知道Kafka是有一个心跳检测的机制，每过设定时间发一次请求确保Kafka消费端存活能正常消费消息，而在设置Kafka心跳参数的时候一定要超过业务的处理时间的，如果业务处理不完，Kafka心跳检测没有得到正常返回的话，就默认消费端与Kafka客户端断开连接（简单描述就是心跳检测后认为你的Kafka死掉了）。这就是kafka为什么会频繁掉线的原因。