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

Question

我是flume-NG的新手。我希望我的源代码将一些独特的xml文件逐个发送到频道。通道将验证xml文件并将有效性（true或false）和xml文件发送到自定义接收器。该接收器会将有效文件和无效文件写入HDFS中的不同目录。我不确定使用哪个来源。请帮忙。

Answer 1

无当前者之中，满足您的使用情况。 SpoolingDirectorySource是面向行的，所以XML文件会混淆而不是一个一个。

我建议你写你的应用程序的自定义源。