开发者社区 问答 正文

Flume内置拦截器中自定义拦截器的步骤是什么?

Flume内置拦截器中自定义拦截器的步骤是什么?

展开
收起
芯在这 2021-12-10 23:03:51 269 分享 版权
1 条回答
写回答
取消 提交回答
  • 步骤:

    1.创建一个项目,并且引入flume对应的依赖依赖

    2.自定义拦截器,实现拦截器接口Interceptor

    3,打成jar包,上传flume的job目录

    4,编写.conf文件,在sources组件中通过拦截器类的全限名路径使用自定义拦截器

    5,测试

    2021-12-10 23:04:18
    赞同 展开评论