Page History

...

The Connect framework also guarantees that by the time preCommit(...) is called on the task, the error reporter will have successfully and fully recorded all reported records with offsets at or before those passed to the preCommit method. To honor the offset.flush.interval.ms configuration, if not all reported records with offsets at or before the latest offset are successfully and fully reported, Kafka Connect will only commit up the last successfully recorded record offset. Sink task implementations that need more strict guarantees can use the futures returned by report(...) to wait for confirmation that reported records have been successfully recorded.

...