Apache Flume with added functionality