Deze pagina is nog niet beschikbaar in uw eigen taal. We werken er hard aan om meer taalversies toe te voegen. Bedankt voor uw steun.

Resetting the Consumer Offset

Updated on 2022-09-14 GMT+08:00

Function

This API is used to reset the consumer offset.

URI

POST /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group_id}/reset-message-offset

Table 1 Path Parameters

Parameter

Mandatory

Type

Description

engine

Yes

String

Engine type. Value: reliability.

Default: reliability

project_id

Yes

String

Project ID.

instance_id

Yes

String

Instance ID.

group_id

Yes

String

Consumer group name.

Request Parameters

Table 2 Request body parameters

Parameter

Mandatory

Type

Description

topic

No

String

Topic to be reset.

timestamp

No

Number

Reset time.

Response Parameters

Status code: 200

Table 3 Response body parameters

Parameter

Type

Description

queues

Array of queues objects

Queues to be reset.

Table 4 queues

Parameter

Type

Description

broker_name

String

Broker where the queue is located.

queue_id

Integer

Queue ID.

timestamp_offset

Integer

Target offset.

Example Requests

Resetting the consumer offset

POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group_id}/reset-message-offset

Example Responses

Status code: 200

Consumer offset reset.

{
  "queues" : [ {
    "broker_name" : "broker-1",
    "queue_id" : 0,
    "timestamp_offset" : 0
  } ]
}

Status Codes

Status Code

Description

200

Consumer offset reset.

Error Codes

See Error Codes.

Feedback

Feedback

Feedback

0/500

Selected Content

Submit selected content with the feedback