使用flume-ng編寫源代碼和自定義接收器

Question

我是flume-NG的新手。我希望我的源代碼將一些獨特的xml文件逐個發送到頻道。通道將驗證xml文件並將有效性（true或false）和xml文件發送到自定義接收器。該接收器會將有效文件和無效文件寫入HDFS中的不同目錄。我不確定使用哪個來源。請幫忙。

Answer 1

無當前者之中，滿足您的使用情況。 SpoolingDirectorySource是面向行的，所以XML文件會混淆而不是一個一個。

我建議你寫你的應用程序的自定義源。