...
Current state: Under Discussion
Discussion thread: TODO here
JIRA: here
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Several new endpoints will be added to the Kafka Connect REST API:
Verb | Path | Summary |
---|---|---|
GET | /connectors/{connector}/offsets | Retrieve the offsets for a connector; the connector must exist |
GET | /offsets/source/{connector} | Retrieve the source offsets for a connector; the connector may or may not exist |
GET | /offsets/sink/{connector}?rawGroupId={true/false} | Retrieve the sink offsets for a connector; the connector may or may not exist |
DELETE | /offsets/source/{connector} | Delete the source offsets for a connector; the connector must not exist |
DELETE | /offsets/sink/{connector}?rawGroupId={true/false} | Delete the sink offsets for a connector; the connector must not exist |
Response format
All responses that return offsets will use one of these formats, depending on whether the offsets are for a source or a sink connector. Care is taken to keep the two formats symmetrical, and suitable for use with both endpoints that require the connector to exist and endpoints that do not.
...