:-:  Flume工作流程 1. Source->Channel 數據由 Source 寫入 Channel，**主動模式**，主要步驟如下： 1）SourceRunner 啟動 Source，Source 接收 Event； 2）Source 調用 ChannelProcessor； 3）ChannelProcessor 調用 Interceptor 進行過濾 Event 操作； 4）ChannelProcessor 調用 ChannelSelector 對象根據配置的策略選擇 Event對應的 Channel（replication 和 multiplexing 兩種）； 5）Source 將 Event 發送到對應的 Channel 中。 2. Channel->Sink 數據由 Sink 主動從 Channel 中**拉取**： 1）SinkRunner 啟動 SinkProcessor（DefaultSinkProcessor，FailoverSinkProcessor，LoadBalancingSinkProcessor 3 種）； 2）如果是 DefaultSinkProcessor 的話，直接啟動單個 Sink； 3）FailoverSinkProcessor，LoadBalancingSinkProcessor 對應的是 SinkGroup； 4）FailoverSinkProcessor 從 SinkGroup 中選擇出 Sink 并啟動； 5）LoadBalancingSinkProcessor 包含 SinkSelector，會根據 SinkSelector 在SinkGroup 中選擇 Sink 并啟動； 6）Sink 從 Channel 中消費 Event 信息。