Force to commit kafka offset when stop a job.

[Lei Wang]

When stopping a flink job that consuming kafka message, how to force it to
commit kafka offset

Thanks,
Lei