Hi Lei. I think you could try to use `stop with savepoint` to stop the job. The offset will be committed when the checkpoint finished. So I think `stop with savepoint` may be helpful.
Best, Hang Lei Wang <leiwang...@gmail.com> 于2024年6月6日周四 01:16写道： > > When stopping a flink job that consuming kafka message, how to force it to > commit kafka offset > > Thanks, > Lei >
