请问我把checkpoint恢复到了23号的时间,为什么启动服务后,kafka消息还是从最新的开始消费, 不是应该从23号开始消费吗?

classic Classic list List threaded Threaded
1 message Options
sun
Reply | Threaded
Open this post in threaded view
|

请问我把checkpoint恢复到了23号的时间,为什么启动服务后,kafka消息还是从最新的开始消费, 不是应该从23号开始消费吗?

sun
请问我把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 &