<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>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                故障轉移組邏輯處理器維護了一個發送 Event 失敗的 sink 的列表,保證有一個 sink 是可用的來發送 Event。 <br/> 故障轉移機制的工作原理是將故障 Sink 降級到一個池中,在池中為它們分配冷卻期(超時時間),在重試之前隨順序故障而增加。 Sink 成功發送事件后,它將恢復到實時池。Sink 具有與之相關的優先級,數值越大,優先級越高。 如果在發送 Event 時 Sink 發生故障,會繼續嘗試下一個具有最高優先級的 Sink。例如,在優先級為 80 的 Sink 之前激活優先級為 100 的 Sink。如果未指定優先級,則根據配置中的順序來選取。<br/> 要使用故障轉移選擇器,不僅要設置 Sink 組的選擇器為 failover,還有為每一個 Sink 設置一個唯一的優先級數值。可以使用 maxpenalty 屬性設置故障轉移時間的上限(毫秒)。<br/> 示例: ```conf ######### Agent ############ a1.sources = r1 a1.channels = c1 a1.sinks = s1 s2 # Sink 組邏輯器 a1.sinkgroups = g1 ######### Sources ########## a1.sources.r1.type = netcat a1.sources.r1.bind = hadoop101 a1.sources.r1.port = 6666 ########## SinkGroups ############# # 將上面定義的sink加入到組中 a1.sinkgroups.g1.sinks = s1 s2 # failover為故障轉移組件 a1.sinkgroups.g1.processor.type = failover # 組內 sink 的權重值,<sinkName>必須是當前組關聯的 sink 之一。數值(絕對值)越高越早被激活 a1.sinkgroups.g1.processor.priority.s1 = 5 a1.sinkgroups.g1.processor.priority.s2 = 10 # 發生異常的 sink 最大故障轉移時間(默認 30000 毫秒) a1.sinkgroups.g1.processor.maxpenalty = 10000 ############ Channel ########### a1.channels.c1.type = memory ########## Sinks ################ a1.sinks.s1.type = avro a1.sinks.s1.hostname = hadoop101 a1.sinks.s1.port = 7777 a1.sinks.s2.type = avro a1.sinks.s2.hostname = hadoop101 a1.sinks.s2.port = 8888 ########## 連接 ########### a1.sources.r1.channels = c1 a1.sinks.s1.channel = c1 a1.sinks.s2.channel = c1 ``` 上面配置了`s1`和`s2`兩個Sink,如果其中一個Sink發生故障,則另一個Sink則開始工作。
                  <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>

                              哎呀哎呀视频在线观看