POST /consumers/{string: group_name}/instances/{string: consumer_instance_id}/offsets
Commits a list of offsets for the consumer. When the post body is empty, it commits all the records that have been fetched by the consumer instance.
Parameters
Parameters | Description |
---|---|
group_name (string) | The name of the consumer group. |
instance_id (string) | The ID of the consumer instance. |
offsets | A list of offsets to commit for partitions. |
offsets[i].topic (string) | Name of the topic |
offsets[i].partition (int) | Partition ID |
offset | The offset to commit. |
Syntax
http://<host>:8082/consumers/<group_name>/instances/<consumer_instance_id>/offsets
Request Example
curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"offsets": [{"topic":
"/mystream:first","partition": 0,"offset":5}]}'
https://node2:8082/consumers/grouptest/instances/user/offsets
Response Example
HTTP/1.1 200 OK