Versions Compared

Key

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

...

Once an offset commit is complete, if the connector is (implicitly or explicitly) configured with a custom separate offsets topic, the committed offsets will also be written to the worker’s global offsets topic using a non-transactional producer and the worker’s principal. This will be handled on a separate thread from the task’s work and offset commit threads, and should not block or interfere with the task at all. If the worker fails to write these offsets for some reason, it will retry indefinitely, but not fail the task. This will be done in order to facilitate "hard" downgrades and cases where users switch from per-connector offsets topics back to the global offsets topic.

...