使用flume-ng编写源代码和自定义接收器

Question

我是第一次接触flume-NG。我希望我的源代码将一些独特的xml文件逐个发送到通道。通道将验证xml文件，并将有效性( true或false)和xml文件发送到自定义接收器。此接收器将有效文件和无效文件写入HDFS中的不同目录。我不确定要使用哪个源码。请帮帮忙。

Answer 1

当前的版本都不适合您的用例。SpoolingDirectorySource是面向行的，所以XML文件会把它搞混，不会一成不变。

我建议您为您的应用程序编写一个自定义源代码。