flume自定义拦截器开发步骤

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

5、启动flume、观察效果。

flume自定义拦截器开发步骤相关推荐

Flume自定义拦截器
需求定义两个拦截器,一个用于过滤不合法数据,一个用于区分日志类型. ETL拦截器主要用于,过滤时间戳不合法和Json数据不完整的日志. 日志类型区分拦截器主要用于,将启动日志和事件日志区分开来,方便 ...
【Spring MVC】自定义拦截器 Interceptor
一.自定义拦截器 1.拦截器,跟过滤器比较像的技术. 1.1 拦截器和过滤器的区别: 拦截器只能拦Controller,Filter可以拦任何请求因为Spring的入口是dispatcherServ ...
mybatis 自定义拦截器
拦截器注解 mybatis自定义拦截器实现步骤: 实现org.apache.ibatis.plugin.Interceptor接口. 添加拦截器注解org.apache.ibatis.plugin.I ...
Flume的开发之自定义 source 自定义 sink 自定义拦截器
一:开发相关加入 jar 包依赖: <dependency> <groupId>org.apache.flume</groupId> <artifactId ...
第1节 flume：15、flume案例二，通过自定义拦截器实现数据的脱敏
1.7.flume案例二案例需求: 在数据采集之后,通过flume的拦截器,实现不需要的数据过滤掉,并将指定的第一个字段进行加密,加密之后再往hdfs上面保存原始数据与处理之后的数据对比图一 ...
flume拦截器及自定义拦截器
拦截器做什么呢? 时间拦截器以时间拦截器为例.会在Event的header中添加一个属性进去,属性的key叫做timestamp, value是当前的毫秒值. 问题是写到header然后呢?有啥用呢 ...
Hadoop生态圈-Flume的组件之自定义拦截器（interceptor）
Hadoop生态圈-Flume的组件之自定义拦截器(interceptor) 作者:尹正杰版权声明:原创作品,谢绝转载!否则将追究法律责任. 本篇博客只是举例了一个自定义拦截器的方法,测试字节传输速 ...
【Flume】（四）IDEA编写自定义拦截器
IDEA编写自定义拦截器 IDEA中导入以下依赖: <!-- https://mvnrepository.com/artifact/org.apache.flume/flume-ng-core ...
Flume四：多路复用（ChannelSelector之Multiplexing）+自定义拦截器
案例: 自定义拦截器 pom.xml <dependency><groupId>org.apache.flume</groupId><artifactId&g ...

flume自定义拦截器开发步骤

flume自定义拦截器开发步骤相关推荐

最新文章

热门文章