You need to enable JavaScript to run this app.
导航
消息队列 Kafka版
  • 文档首页
    • /
  • 消息队列 Kafka版

ResetConsumedOffsets

最近更新时间：2022.10.18 16:24:27

首次发布时间：2022.04.24 15:56:38

我的收藏

调用 ResetConsumedOffsets 重置消费者组消费的 Offset。

使用说明

ResetConsumedOffsets 接口用于重置消费者组在某个分区的消费 Offset，重置 offset 可能会导致重复消费，请谨慎操作。

  • 此接口的 API Version 为 2018-01-01。
  • 此接口的调用频率限制为 20 次/s，超出频率限制会报错 “AccountFlowLimitExceeded”。

请求参数

参数参数类型是否必选示例值说明
InstanceIdString是kafka-****x需要重置消费位点的实例 ID。
GroupIdString是my_group需要重置消费位点的消费组 ID。
OffsetsList是my_group需要重置的消费位点信息。详细信息请参考 ResetOffset。

响应参数

无

示例

请求示例

POST https://kafka.volcengineapi.com/?Action=ResetConsumedOffsets&Version=2018-01-01 HTTP/1.1
Accept: application/json
Content-Type: application/json
Host: kafka.volcengineapi.com
X-Date: 20210328T100802Z
Authorization: HMAC-SHA256 Credential=AK********/20210328/cn-beijing/kafka/request, SignedHeaders=x-date, Signature=********

{
  "InstanceId": "kafka-****x",
  "GroupId": "my_group",
  "Offsets": [
    {
      "TopicName": "my_topic",
      "PartitionNumber": 3,
      "ResetType": "Timestamp",
      "ResetValue": 1628782942
    }
  ]
}

响应示例

{
  "ResponseMetadata": {
    "RequestId": "****************",
    "Action": "ResetConsumedOffsets",
    "Version": "2018-01-01",
    "Service": "kafka",
    "Region": "cn-beijing"
  },
  "Result": null
}