Versions Compared

Key

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

...

Code Block
languagejs
titleSink offsets request
{
  "offsets": [
    {
      "partition": {
        "kafka_topic": // Kafka topic
        "kafka_partition": // Kafka partition
	  },
      "offset": {
        "kafka_offset": // Kafka offset
      }
    }
  ]
}

For either kind of connector, the offset field may be null , which will reset the offset for that specific partition. For example, to reset the offset for partition 3 of a topic T read by a sink connector:

Code Block
languagejs
titleSink offsets request (patch reset)
{
  "offsets": [
    {
      "partition": {
        "kafka_topic": "T"
        "kafka_partition": 3
	  },
      "offset": null
    }
  ]
}

Altering/resetting offsets (response)

...