DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| 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
| Properties | Default | Description |
|---|---|---|
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.enabledandemit.heartbeat.enabledthis KIP will addemit.offset-syncs.enabled. The config default value will be true to keep the current implementation. offset-syncs topic will not be created ifemit.offset-syncs.enabled set to falselogic to publish offset syncs in commit()will not be executed ifemit.offset-syncs.enabled set to false
...