步骤如下：
1、新建一个java项目，不需要依赖spring等一系列依赖。只需要加上你用的 工具类的依赖。flume的依赖不用加，因为服务器里面有。
2、实现Interceptor接口，重写里面的intercept方法，把你的逻辑写好，然后返回event。
3、打包，打的包是很小的那种，没有其他杂七杂八的依赖包。放入flume的lib文件夹里面。
4、修改配置文件，将自定义拦截器类的全路径配置上：
5、启动flume、观察效果。
步骤如下：
1、新建一个java项目，不需要依赖spring等一系列依赖。只需要加上你用的 工具类的依赖。flume的依赖不用加，因为服务器里面有。
2、实现Interceptor接口，重写里面的intercept方法，把你的逻辑写好，然后返回event。
3、打包，打的包是很小的那种，没有其他杂七杂八的依赖包。放入flume的lib文件夹里面。
4、修改配置文件，将自定义拦截器类的全路径配置上：
5、启动flume、观察效果。
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
