自带的spoolDirSource不像avroSource一样可以加文件头,所以我们需要自定义

步骤:

1.在项目目录下的Maven dependencies下找
Flume spoolDirSource 无法加header怎么办

下面选中的的:
Flume spoolDirSource 无法加header怎么办

2.自己新建一个MySpoolDirectorySource的java class,将上面那个SpoolDirectorySource.class中的所有代码自己复制过去,改一下类名就行。

3.找到run方法,在下面写逻辑:
Flume spoolDirSource 无法加header怎么办

4 .导出jar包,整个项目导出来。
5.修改linux上flume的配置文件,用自己的这个Source,
修改前:
Flume spoolDirSource 无法加header怎么办
修改后:
Flume spoolDirSource 无法加header怎么办

获取函数全路径:右键函数名->copy qualified name

6.结束,启动flume

相关文章:

  • 2021-10-21
  • 2021-08-25
  • 2021-04-07
  • 2021-08-21
  • 2021-08-28
  • 2021-08-22
  • 2022-02-23
猜你喜欢
  • 2021-04-01
  • 2021-09-14
  • 2021-08-04
  • 2021-05-30
  • 2021-10-26
  • 2022-12-23
  • 2021-12-14
相关资源
相似解决方案