#

自定義source

  • Flume自定義Source

    模擬編寫(xiě)了一個(gè)Flume 1.7中TAILDIR的功能實(shí)現(xiàn)，通過(guò)手動(dòng)控制文件的讀取位置來(lái)達(dá)到對(duì)文件的讀寫(xiě)，防止flume掛了之后重復(fù)消費(fèi)的情況。以下是代碼實(shí)現(xiàn)，僅做參考，生產(chǎn)上直接用TAILDIR讀取

    作者：興趣e族
    2020-07-20 15:01:34