Versions Compared


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


  • 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 

  • MirrorCheckpointConnector validation will fail to at start if emit.offset-syncs.enabled disabled while emit.checkpoints.enabled and/or are enabled.