Consumer rebalance失敗問題定位和解決思路

背景 最近在公司使用Kafka的Consumer高級API出現一些問題，問題描述如下：  大象push推送隊列，在(大約每天8點到10點間)發送消息高峯期，消費節點負載處於高位、jvm內存佔用大於%80。這時候JVM會頻繁持續FullGC而卡住異步線程(stop the world)，心跳等異步線程就沒法正常收發數據包。這種情況下導致zk會話過期觸發Consumer rebalance，zk會話過

>>阅读原文<<