开发者社区> 问答> 正文

Flume企业开发中自定义 Source的流程有哪些呢?

Flume企业开发中自定义 Source的流程有哪些呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-06 08:16:58 305 0
1 条回答
写回答
取消 提交回答
  • 1.定义 MySource 类,继承 AbstractSource 类并实现 Configurable 和 PollableSource 接口。之后将 Maven 项目打成 jar 包上传到 /opt/module/flume/lib 目录下

    2.创建配置文件 mySource.conf

    3.开启任务

    4.在控制台查看结果

    2021-12-06 10:47:12
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
零基础实现Flume收集网站日志数据到MaxCompute 立即下载
《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》 立即下载
基于HBase和Spark构建企业级数据处理平台 立即下载