flume--自定義可記錄偏移量的TailFileSource

使用flume實時採集Nginx產生的log數據時，如果機器宕機了，數據就會丟失，而且會重複讀取數據，那麼避免這種情況的發生，我們就要自定義一個可以記錄偏移量的Source。 這裏使用TailFileSource，一次監聽一個文件。 代碼如下：（根據execSource源碼編寫） package cn.edu360.flume.source; import org.apache.commons.

>>阅读原文<<