调用 ModifyCheckPoint 接口为指定消费组重置指定分区的消费位点。
重置消费位点之前,应关闭对应的消费进程,否则消费位点重置失败。
下表仅列出该接口特有的请求参数和部分公共参数。更多信息请见公共参数。
参数 | 类型 | 是否必选 | 示例值 | 描述 |
---|---|---|---|---|
ProjectID | String | 是 | c7****** | 待修改 CheckPoint 的日志项目 ID。 |
TopicID | String | 是 | b6****** | 待修改 CheckPoint 的日志主题 ID。 |
ShardID | Integer | 是 | 0 | 待修改 CheckPoint 的 Shard ID。 |
ConsumerGroupName | String | 是 | my-consumer-group | 待修改 CheckPoint 的消费组名称。 |
Checkpoint | String | 是 | M******** | 消费位点,即消费进度。 |
本接口无特有的返回参数。更多信息请见返回结构。
PUT https://tls-{Region}.ivolces.com/ModifyCheckpoint HTTP/1.1 Content-Type: application/json { "ProjectID": "c7************", "TopicID": "b6********", "ShardID": 0, "ConsumerGroupName": "my-consumer-group", "Checkpoint": "NjUwYzRkYTgtMi0wMDAwMDAwMDAwMDAwMzE0LTAwNGY1LTA=" }
HTTP/1.1 200 OK Content-Type: application/json; charset=utf-8
下表为您列举了该接口与业务逻辑相关的错误码。公共错误码请参见公共错误码文档。
HTTP 状态码 | 错误码 | 错误信息 | 说明 |
---|---|---|---|
400 | InvalidArgument | Invalid argument key %s, value %s, please check argument. | 参数不合法。 |
500 | InternalServerError | We encountered an unexpected server error, please try again later. | 服务器内部错误。 |