負載均衡維護一個活動 Sink列表的索引來實現負載的分配。支持了 **輪詢（round_robin）** 和 **隨機（random）** 兩種選擇機制分配負載，默認是輪詢，可以通過配置來更改。也可以從 AbstractSinkSelector 繼承寫一個自定義的選擇器。 :-:  負載均衡 Agent1會根據負載的機制來選擇上面三個Sink中的哪一個進行工作。 <br/> 工作時，此選擇器使用其配置的選擇機制選擇下一個 Sink 并調用它。如果所選Sink無法正常工作，則處理器通過其配置的選擇機制選擇下一個可用Sink。此實現不會將失敗的 Sink 列入黑名單，而是繼續樂觀地嘗試每個可用的 Sink。 <br/> 如果所有 Sink 調用都失敗了，選擇器會將故障拋給 Sink 的運行器。<br/> 如果backoff設置為true則啟用了退避機制，失敗的Sink會被放入黑名單，達到一定的超時時間后會自動從黑名單移除。如從黑名單出來后Sink仍然失敗，則再次進入黑名單而且超時時間會翻倍，以避免在無響應的 Sink 上浪費過長時間。 如果沒有啟用退避機制，在禁用此功能的情況下，發生 Sink 傳輸失敗后，會將本次負載傳給下一個 Sink 繼續嘗試，因此這種情況下是不均衡的。<br/> 示例： ```conf ######### Agent ############ a1.sources = r1 a1.channels = c1 a1.sinks = s1 s2 s3 # 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 s3 # load_balance為負載均衡組件 a1.sinkgroups.g1.processor.type = load_balance # 失敗的 sink 是否成倍地增加退避它的時間。 a1.sinkgroups.g1.processor.backoff = true # 負載均衡機制，可選值：round_robin （輪詢）、 random （隨機選擇）、「自定義選擇器的全限定類名」 a1.sinkgroups.g1.processor.selector = random ############ 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.sinks.s3.type = avro a1.sinks.s3.hostname = hadoop101 a1.sinks.s3.port = 9999 ########## 連接 ########### a1.sources.r1.channels = c1 a1.sinks.s1.channel = c1 a1.sinks.s2.channel = c1 a1.sinks.s3.channel = c1 ```