文章浏览阅读63次。文章目录1 自定义 Interceptor1.1 案例需求1.2 需求分析1.3 实现步骤2 自定义 Source2.1 介绍2.2 需求2.3 编码3 自定义 Sink3.1 介绍3.2 需求1 自定义 Interceptor1.1 案例需求使用 Flume 采集服务器本地日志，需要按照日志类型的不同，将不同种类的日志发往不同的分析系统。1.2 需求分析在实际的开发中，一台服务器产生的日志类型可能有很多种，不同类型的日志可能需要发送到不同的分析系统。此时会用到 Flume 拓扑结构中的 Mul_org.apache.flume.event依赖