《大数据: Flume 自定义Interceptor》

it2026-08-14  12

一、Flume 自定义Interceptor (拦截器)

需求:

在实际的开发中,一台服务器产生的日志类型可能有很多种,不同类型的日志可能需要发送到不同的分析系统。此时会用到Flume拓扑结构中的Multiplexing结构,Multiplexing的原理是,根据event中Header的某个key的值,将不同的event发送到不同的Channel中,所以我们需要自定义一个Interceptor,为不同类型的event的Header中的key赋予不同的值

::演示案例简单一点,我们就写一个拦截器为每个事件head 中添加时间戳

 

最新回复(0)