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

ResetConsumedOffsets

最近更新时间：2023.08.09 16:02:16

首次发布时间：2023.03.30 19:59:26

我的收藏

调用 ResetConsumedOffsets 重置消费者组的消费位点。

使用说明

此接口用于重置指定消费组的消费位点，改变订阅者当前的消费位置，即直接从某个指定时间点、最新 offset 位点或指定 offset 位点来消费消息。

说明

  • 消息队列 Kafka版不支持在线重置消费位点，在重置消费位点之前，必须停止 Consumer Group 中的所有消费者客户端，确保 Group 的状态为 Empty。
  • 停止消费者客户端后，需要经过指定的超时时间，服务端才认为 Consumer 真正下线。其中超时时间为 ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG 配置的时间，默认 10000ms。

请求参数

参数

参数类型

是否必选

示例值

说明

InstanceId

String

是

kafka-cnngbnntswg1****x

需要重置消费位点的实例 ID。

GroupId

String

是

my_group

需要重置消费位点的消费组 ID。

ResetOffsetsInfo

Array of ResetOffsetInfoObject

是

/

需要重置的消费位点信息。详细信息请参考数据结构中的 ResetOffsetInfoObject 部分。

响应参数

无

示例

请求示例

POST /?Action=ResetConsumedOffsets&Version=2022-05-01 HTTP/1.1
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-cnng1si21igu****",
  "GroupId":"Group",
  "ResetOffsetsInfo": {
      "TopicName": "test",
      "PartitionId":0,
      "ResetType": "Offset",
      "ResetOffset": -1
  }
}

响应示例

{
    "ResponseMetadata": {
        "RequestId": "20230227211906E9F948120F87D27F1AEE",
        "Action": "ResetConsumedOffsets",
        "Version": "2022-05-01",
        "Service": "Kafka",
        "Region": "cn-beijing"
    },
    "Result": null
}