如何编写用于在hdfs接收器上创建avro文件的自定义flume-ng源代码？

Question

我想写一个可以在hdfs接收器上创建avro文件的CustomSource。但我无法弄清楚。

希望看到一些指导方针或示例。

Answer 1

这将帮助你了解详细内容： https://flume.apache.org/FlumeUserGuide.html

但在高水平上创建自定义水槽来源： 1.更改水槽配置。在此添加源配置并将其指向MyCustomSource.java 2.在MyCustomSource.java中编写源逻辑并将该jar复制到flume节点并重新启动。