<ins>Kafka 容災指當 Broker 宕機時的恢復機制</ins>。<mark>在 Kafka 集群中會有一個或者多個 Broker，其中有一個 Broker 會被選舉為控制器（Kafka Controller），它負責管理整個集群中所有分區和副本的狀態。</mark> <br/> ? 當某個分區的 Leader 副本出現故障時，由控制器負責為該分區選舉新的Leader 副本。 ? 當檢測到某個分區的 ISR 集合發生變化時，由控制器負責通知所有Broker 更新其元數據信息。 ? 當使用 kafka-topics.sh 腳本為某個 topic 增加分區數量時，同樣還是由控制器負責分區的重新分配。 <br/> Kafka中的控制器選舉的工作依賴于ZooKeeper，成功競選為控制器的Broker會在 ZooKeeper 中創建/controller 這個臨時（EPHEMERAL）節點，此臨時節點的內容參考如下： ``` {"version":1,"brokerid":0,"timestamp":"1561214469054"} ``` brokerid 表示稱為控制器的 Broker 的 id 編號，timestamp 表示競選稱為控制器時的時間戳。 <br/> Broker 容災流程如下： 1. Controller 在 ZooKeeper 的 `/brokers/ids/[brokerId]` 節點注冊 Watcher，當Broker 宕機時 ZooKeeper 會監聽到。 2. Controller 從/brokers/ids 節點讀取可用 Broker。 3. Controller 決定 set_p，該集合包含宕機 Broker 上的所有 Partition。 4. 對 set_p 中的每一個 Partition： （1）從`/brokers/topics/[topic]/partitions/[partition]/state` 節點讀取 ISR； （2）決定新 Leader； （3）將新 Leader、ISR、controller_epoch 和 leader_epoch 等信息寫入 state節點。 5. 通過 RPC 向相關 Broker 發送 leaderAndISRRequest 命令。