Page History

...

The SourceTask::commit and SourceTask::commitRecord methods will be invoked immediately after each successful offset commit, including the end-of-life offset commit that takes place during task shutdown. First, commitRecord will be invoked for every record in the committed batch, followed by a call to commit. It is possible that the worker or task may suddenly die in between a successful offset commit and the completion of these calls.

...