Flink的checkpointing机制对流和状态的可靠存储有如下两点要求：持久化的数据源能够从某个时间进行消息回放。举个例子，对于消息队列而言，有Kafka，RabbitMQ，Kinesis，Pu...