flume--自定义可记录偏移量的TailFileSource

使用flume实时采集Nginx产生的log数据时，如果机器宕机了，数据就会丢失，而且会重复读取数据，那么避免这种情况的发生，我们就要自定义一个可以记录偏移量的Source。 这里使用TailFileSource，一次监听一个文件。 代码如下：（根据execSource源码编写） package cn.edu360.flume.source; import org.apache.commons.

>>阅读原文<<