flume自定义拦截器开发步骤

最新推荐文章于 2023-02-10 11:32:39 发布

csdn1949_406

最新推荐文章于 2023-02-10 11:32:39 发布

阅读量1.3k

点赞数 1

文章标签：大数据 flume etl

本文链接：https://blog.csdn.net/csdn1949_406/article/details/124573799

版权

步骤如下：
1、新建一个java项目，不需要依赖spring等一系列依赖。只需要加上你用的工具类的依赖。flume的依赖不用加，因为服务器里面有。
2、实现Interceptor接口，重写里面的intercept方法，把你的逻辑写好，然后返回event。
3、打包，打的包是很小的那种，没有其他杂七杂八的依赖包。放入flume的lib文件夹里面。
4、修改配置文件，将自定义拦截器类的全路径配置上：
这里插入图片描述
5、启动flume、观察效果。