Flume中的攔截器是可以自定義的。思路如下： （1）實現Interceptor接口，并重新該接口的幾個核心方法 ```java package com.flume.interceptor; import org.apache.flume.interceptor.Interceptor; // 實現Interceptor接口 public class MyInterceptor implements Interceptor { // 重寫intercept(Event event)方法 public Event intercept(Event event) { byte[] body = event.getBody(); // 拿到body就可以按照需求來過濾數據了，最后返回一個新的Event return newEvent; } // 重寫intercept(List<Event> events)方法 public LIst<Event> intercept(List<Event> events) { for (Event event : events) { intercept(event); // 調用上面的重載方法 } return newListEvent; } } ``` （2）將程序打包為jar上傳到服務器的 {flume_home}/lib/ 目錄下 （3）然后在配置文件中使用自定義的攔截器 ```conf agent.sources.s1.interceptors.il.type = com.flume.interceptor.MyInterceptor ```