Flume使用詳解(四)

flume的Interceptors 概述: Flume有能力在運行階段修改/刪除Event,這是通過攔截器(Interceptors)來實現的。 攔截器需要實現org.apache.flume.interceptor.Interceptor接口。 攔截器可以修改或刪除事件基於開發者在選擇器中選擇的任何條件。 攔截器採用了責任鏈模式,多個攔截器可以按指定順序攔截。 一個攔截器返回的事件列表被傳遞給
相關文章
相關標籤/搜索