> For the complete documentation index, see [llms.txt](https://docs.lenses.io/latest/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://docs.lenses.io/latest/k2k/1.0/configuration/coordination.md). # Coordination ### Offset Commit K2K keeps track of progress by periodically committing offsets indicating the last offset it replicated. Rather than using the Consumer Group API to commit offsets, K2K utilizes instead a control topic in the target cluster to write and store this information. Bellow, it's a table of the configuration options that allow tweaking this process.

Property Path	Description	Default	Required
`coordination.commit.topic`	Control topic that holds the commit information.	`__k2k_consumer-offsets`	No
`coordination.commit.syncTimeout`	Max amount of time K2K will spend attempting to read the contents of the offset commit control topic	30 seconds	No
`coordination.commit.batchSize`	Max number of records produced before a commit message is also produced.	1000	No
`coordination.commit.batchTimeout`	Max amount of time between commit messages are produced.	2 seconds	No

### Exclusive Assignment When `features.exactlyOnce` is used, K2K needs to make sure that at any given time, not more than one Producer is producing data for the same Source Topic Partition.\ Due to the lack of support for inter-cluster transactions, K2K has a custom strategy in order to guarantee the aforementioned invariant holds. Bellow, it's a table of the configuration options that allow tweaking this process.

Property Path Description Default Required

Property Path	Description	Default	Required
`coordination.assignment.topic`	Control topic where K2K instances will publish information about which partitions they are using.	`__k2k_assignment`	No
`coordination.assignment.graceWindow`	Max amount of time an instance will wait before fencing a producer that owns a partition the current instance was assigned.	`15 seconds`	No
`coordination.assignment.fencingMaxParallelism`	Controls how many producers can be fenced in parallel .	`5`	No

coordination.assignment.topic

Control topic where K2K instances will publish information about which partitions they are using.

__k2k_assignment

coordination.assignment.graceWindow Max amount of time an instance will wait before fencing a producer that owns a partition the current instance was assigned. 15 seconds No

coordination.assignment.fencingMaxParallelism Controls how many producers can be fenced in parallel . 5 No

--- # Agent Instructions This documentation is published with GitBook. GitBook is the documentation platform designed so that both humans and AI agents can read, navigate, and reason over technical content effectively. Learn more at gitbook.com. ## Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter, and the optional `goal` query parameter: ``` GET https://docs.lenses.io/latest/k2k/1.0/configuration/coordination.md?ask=&goal= ``` `ask` is the immediate question: it should be specific, self-contained, and written in natural language. `goal` is optional and describes the broader end goal you are ultimately trying to accomplish on behalf of the user. GitBook uses it to tailor the answer towards what is most useful for that goal. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.