Kafka instances do not support resetting the consumer offset online. Before resetting, stop the client for which the offset is to be reset.After a client is stopped, the server considers the client offline only after the time period specified in ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG (1000 ms by default).
POST /v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
project_id |
Yes |
String |
Project ID. For details about how to obtain it, see Obtaining a Project ID. |
instance_id |
Yes |
String |
Instance ID. |
group |
Yes |
String |
Consumer group name. |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
topic |
No |
String |
Topic name. |
partition |
Yes |
Integer |
Partition number. The default value is -1, indicating that all partitions are reset. |
message_offset |
No |
Long |
Resetting consumer group offset to the specified position.
Either message_offset or timestamp must be specified. |
timestamp |
No |
Long |
Specified time that the offset is to be reset to. The value is a Unix timestamp, in millisecond.
Either message_offset or timestamp must be specified. |
None
Resetting consumer group offset to the specified position.
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset { "topic" : "test", "partition" : 0, "message_offset" : 10 }
Resetting consumer group offset to the specified time.
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset { "topic" : "test", "partition" : 0, "timestamp" : 1571812144000 }
None
Status Code |
Description |
---|---|
204 |
The consumer group offset is successfully reset to the specified position. |
See Error Codes.