|
请问我把checkpoint恢复到了23号的时间,为什么启动服务后,kafka消息还是从最新的开始消费, 不是应该从23号开始消费吗?
nohup /opt/flink-1.10.2/bin/flink run -c com.toonyoo.app.data.realcomputation.Application /home/test/ty-app-data-real-computation-1.0.jar -s /opt/flink-1.10.2/checkpoints/f1e8c6bfca15c041c7b3dcf99abfffea/chk-1/_metadata &
|