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

Table 1. 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