THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
{ "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 | ||||
---|---|---|---|---|
| ||||
{
"offsets": [
{
"partition": {
"kafka_topic": "T"
"kafka_partition": 3
},
"offset": null
}
]
} |
Altering/resetting offsets (response)
...