Versions Compared

Key

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

...

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:

VerbPathSummary
GET/connectors/{connector}/offsetsRetrieve 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.

...