Apache Flume + Esper CEP