故障轉移組邏輯處理器維護了一個發送 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則開始工作。