#

自定义source

  • Flume自定义Source

    模拟编写了一个Flume 1.7中TAILDIR的功能实现,通过手动控制文件的读取位置来达到对文件的读写,防止flume挂了之后重复消费的情况。以下是代码实现,仅做参考,生产上直接用TAILDIR读取

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