A reactive dataflow engine, a data stream processing framework using Vert.x - View it on GitHub