1、创建Maven工程flume-interceptor
2、创建包名:com.atguigu.flume.interceptor
3、在pom.xml文件中添加如下配置

4、在interceptor包下创建Log类名
Flume ETL拦截器LogETLInterceptor

5、Flume日志过滤工具类

6、Flume日志类型区分拦截器LogTypeInterceptor

7、打包
拦截器打包之后,只需要单独包,不需要将依赖的包上传。打包之后要放入flume的lib文件夹下面。

8、采用root用户将flume-interceptor包放入到hadoop102的/opt/cloudera文件夹下面。

9、分发Flume到hadoop103

10、启动Flume,并查看日志
