An example of using Flink for Fault-Tolerant Stream Processing - View it on GitHub