如果消费位置不准确了，或者checkpoint/savepoint损坏无法恢复，可以直接在Flink中方便指定消费者位置；
如下示例直接指定消费的时间戳即可。（Flink Sql好像还不支持，需要单独写UDF实现）
参考：
