步骤如下：
1、新建一个java项目，不需要依赖spring等一系列依赖。只需要加上你用的 工具类的依赖。flume的依赖不用加，因为服务器里面有。
2、实现Interceptor接口，重写里面的intercept方法，把你的逻辑写好，然后返回event。
3、打包，打的包是很小的那种，没有其他杂七杂八的依赖包。放入flume的lib文件夹里面。
4、修改配置文件，将自定义拦截器类的全路径配置上：
5、启动flume、观察效果。
本文转载自: https://blog.csdn.net/csdn1949_406/article/details/124573799
版权归原作者 csdn1949_406 所有， 如有侵权，请联系我们删除。
版权归原作者 csdn1949_406 所有， 如有侵权，请联系我们删除。