<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ??一站式輕松地調用各大LLM模型接口,支持GPT4、智譜、豆包、星火、月之暗面及文生圖、文生視頻 廣告
                <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 命令。
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看