是否有可能检查flume中空通道/接收器的内容?

6ojccjat  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(426)

我想确保Flume正常工作,不丢弃符合我的选择标准的事件。

yfwxisqw

yfwxisqw1#

可能您可以使用file\u roll sink将完整的事件记录到一个文件中,然后您可以在该文件上应用过滤逻辑(无论您在拦截器中使用哪个逻辑)来获得过滤事件的列表。然后可以与Flume过滤事件进行匹配和验证。如果您要处理大量的事件,那么您可以在采样期间执行此操作。
注意:要测试上述解决方案,可以为同一个源创建两个不同的通道,以便一个用于日志记录,另一个用于过滤

相关问题