Hi, you could stop the job with a final savepoint [1]. Flink which will trigger a final offset commit on the final savepoint.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/cli/#stopping-a-job-gracefully-creating-a-final-savepoint Best, Zhanghao Chen ________________________________ From: Lei Wang <leiwang...@gmail.com> Sent: Wednesday, June 5, 2024 22:47 To: user <user@flink.apache.org> Subject: Force to commit kafka offset when stop a job. When stopping a flink job that consuming kafka message, how to force it to commit kafka offset Thanks, Lei
