Versions Compared

Old Version 3

changes.mady.by.user Shikhar Bhushan

Saved on

compared with

New Version 4

changes.mady.by.user Shikhar Bhushan

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • When checking whether an offset commit is 'due' as per offset.flush.interval.ms, any pending commit request from the connector via SinkTaskContext.requestCommit() is also taken into consideration. Starting a commit clears any such pending request.
  • Instead of invoking SinkTask.flush() as part of the offset commit process, SinkTask.preCommit() is invoked and the returned offset state committed.
  • SinkTask.flush() is invoked directly by the runtime only prior to SinkTask.close().

The motivating use-cases are met as follows:

...