Consumer rebalance失败问题定位和解决思路

背景 最近在公司使用Kafka的Consumer高级API出现一些问题，问题描述如下：  大象push推送队列，在(大约每天8点到10点间)发送消息高峰期，消费节点负载处于高位、jvm内存占用大于%80。这时候JVM会频繁持续FullGC而卡住异步线程(stop the world)，心跳等异步线程就没法正常收发数据包。这种情况下导致zk会话过期触发Consumer rebalance，zk会话过

>>阅读原文<<