Versions Compared

Old Version 8

changes.mady.by.user Unknown User (omnia)

Saved on

compared with

New Version 9

changes.mady.by.user Unknown User (omnia)

Saved on

Key

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

...

  1. MirrorSourceConnector : this connector stores the translation of the new recored's offset record offsets on target cluster in offset_syncs  internal topic after mirroring the record itself. This translation is done at commit  method since 3.5 where commit()  API stores the offsets in the source system, up to the offsets that have been returned by poll()  . The implementation of this API should block until the commit is complete. See [KAFKA-14610](https://issues.apache.org/jira/browse/KAFKA-14610) for more details.
  2. MirrorCheckpointConnector : this connector uses the new record offsets from offset_syncs  and update checkpoints  and __consumer_offsets  topics. This can be controlled by emit.checkpoints.enabled  and sync.group.offsets.enabled 

...