Kafka消費者之Group Coordinator原理

消費者是如何實現rebalance的？ 1. 什麼是coordinator？ 每個consumer group 都會選擇一個broker作爲自己的coordinator，他是負責監控整個消費組裏的各個分區的心跳，以及判斷是否宕機，和開啓rebalance的。 2. 如何選擇coordinator機器 首先對group id 進行hash，接着對__consumer_offsets的分區數量進行取模

>>阅读原文<<