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

bweufnob  于 2021-06-03  发布在  Flume
关注(0)|答案(1)|浏览(390)

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

pbpqsu0x

pbpqsu0x1#

目前没有一个适合您的用例。这个 SpoolingDirectorySource 是面向行的,所以xml文件会混淆它,而不是一块一块地到达。
我建议您为您的应用程序编写一个自定义源代码。

相关问题