Flume使用详解(四)

flume的Interceptors 概述: Flume有能力在运行阶段修改/删除Event,这是通过拦截器(Interceptors)来实现的。 拦截器需要实现org.apache.flume.interceptor.Interceptor接口。 拦截器可以修改或删除事件基于开发者在选择器中选择的任何条件。 拦截器采用了责任链模式,多个拦截器可以按指定顺序拦截。 一个拦截器返回的事件列表被传递给链中的下一个拦截器。 如果一个拦截器需要删除事件,它只需要在返回的事件集中不包含要删除的事件即可。 如果要删除所有事件,只需返回一个空列表。 Timestamp Interceptor 这个拦截器在事