A simple distributed stream-processing system implementation for Educational purpose.