1，启动命令
在bin目录下
flume-ng.cmd agent -conf ../conf -conf-file ../conf/spooling.conf -name a1 -property flume.root.logger=INFO,console
2，自定义拦截器
实现org.apache.flume.interceptor.Interceptor 实现intercept方法，对event，既每一行信息操作
3，pom
<dependency>
<groupId>org.apache.flume</groupId>
<artifactId>flume-ng-core</artifactId>
<version>1.6.0</version>
</dependency>
4，spooling.confg
flume
原文地址：https://www.cnblogs.com/sycode/p/8157350.html