一次kafka一直rebalance的定位與處理

前端時間咱們自研了一個kafka->elasticsearch導數據的小程序，咱們啓動了多個副本。因爲須要限速，可能會有中止接收消息的時間段，會致使中止和kafka的心跳，致使kafka一直處於rebalance的狀態，經過查閱文檔發現下面相關的幾個參數前端 session.timeout.ms is for heartbeat thread. If coordinator fails to ge

>>阅读原文<<