flume-ng源碼淺析

1.架構   Source： 負責產生數據，將數據「傳入」到channel，一旦寫入channel成功，source就認爲數據已經可靠的傳輸。   Sink：    sink不停的從屬於自己的channel（此處有點類似於消息隊列的消費者了）中獲取數據，並且將數據寫入到相應的後端中，如果數據寫入失敗則需要將相應的狀況通知channel，讓channel知道數據傳輸失敗，下次獲取時可以繼續獲取到這些

>>阅读原文<<