Versions Compared

Key

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

...

Code Block
languagejs
titleSink offsets
{
  "type": "SINK",
  "offsets": [
    {
      "partition": {
        "topic": // Kafka topic
        "partition": // Kafka partition
	  },
      "offset": {
        "offset": // Kafka offset
      }
    }
  ]
}

Offsets endpoints behavior

The GET /connectors/{connector}/offsets  endpoint will be useful for examining the offsets of a currently-running connector. It will automatically deduce whether the connector is a source or sink based on the connector's configuration, and then return the offsets for the connector. The request will fail with a 404 response if the connector does not exist on the cluster.

...