Versions Compared

Key

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

Table of Contents

Status

Current state: Draft Under Discussion

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA: here

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

This KIP propose that we add a new config for MirrorSourceConnector  to control enabling the offsets translation between clusters for replicated topics.

Public Interfaces

PropertiesDefaultDescription
emit.offset-syncs.enabled true

Whether to store the new offset of the replicated records in offset-syncs topic or not.

Proposed Changes

  • Similar to emit.checkpoints.enabled  and emit.heartbeat.enabled  this KIP will add emit.offset-syncs.enabled. The config default value will be true to keep the current implementation.
  • offset-syncs topic will not be created if emit.offset-syncs.enabled set to false 

  • logic to publish offset syncs in commit() will not be executed if emit.offset-syncs.enabled set to false 

...