title: Filtering log files in Flume using interceptors
body: <p>I have an http server writing log files which I then load into HDFS using Flume
  First I want to filter data according to data I have in my header or body. I read that I can do this using an interceptor with regex, can someone explain exactly what I need to do? Do I need to write Java code that overrides the Flume code?</p>
  
  <p>Also I would like to take data and according to the header send it to a different sink (i.e source=1 goes to sink1 and source=2 goes to sink2) how is this done?</p>
  
  <p>thank you,</p>
  
  <p>Shimon</p>