重置消费组位点

更新时间：2023-06-30

该接口用于重置集群中指定消费组的位点数据。

集群处于服务中状态（ACTIVE）。

请求结构

                Java
                
            

                POST /v{version}/clusters/{clusterId}/consumer-groups/{groupName}/offsets HTTP/1.1
Host: kafka-api.bd.baidubce.com
Authorization: authorization string
  
{
    "topicName": "topicName",
    "partitions": [0, 1],
    "resetStrategy": "resetStrategy",
    "resetValue": "resetValue"
}
            

请求头域

除公共头域外，无其他特殊头域。

请求参数

参数名称	类型	是否必须	参数位置	描述
version	String	是	URL参数	API版本号
clusterId	String	是	URL参数	待重置消费组位点的集群ID
groupName	String	是	URL参数	待重置位点的消费组名称
topicName	String	是	RequestBody参数	待重置位点的topic名称
partitions	List	是	RequestBody参数	topic重置位点的分区ID
resetStrategy	String	是	RequestBody参数	重置位点的策略类型，可选值为： tooffset：该策略用于将消费位点重置到某个具体的值，由resetValue指定具体的位点值 shiftby：该策略用于将消费位点重置到当前位点的前方或者后方某个偏移量的值，由resetValue指定具体的偏移量。例如：当前位点为100，使用该策略传入10，则会将当前位点重置为110；如果传入-10，则会将当前位点重置为90 todatetime：将消费位点重置到某个时间点，由resetValue指定具体的时间点值 toearliest：将消费位点重置到最早位点 tolatest：将消费位点重置到最新位点
resetValue	String	否	RequestBody参数	重置位点时的参数值，具体配置与resetStrategy的值有关，下列为resetStrategy参数值在不同情况下，resetValue的配置说明： tooffset：resetValue需要配置为具体的位点值 shiftby：resetValue需要配置为某个偏移量的值 todatetime：resetValue需要配置为某个具体的时间值 toearliest：resetValue无需配置 tolatest：resetValue无需配置

返回头域

除公共头域外，无其他特殊头域。

返回参数

参数名称	类型	描述
groupName	String	成功重置位点的消费组名称

错误码

错误码	错误描述	HTTP状态码	描述
ERROR_PARAMS	请求参数错误	400	请求参数错误
CLUSTER_NOT_FOUND	集群不存在	451	集群不存在
CLUSTER_HAD_DELETED	集群已删除	451	集群已删除
CLUSTER_NOT_BELONGED	未拥有该集群	451	未拥有该集群
CLUSTER_NOT_AVAILABLE	集群不可用	451	集群不可用
CONSUMER_GROUP_NOT_FOUND	消费组不存在	451	消费组不存在
TOPIC_NOT_EXIST	主题不存在	451	主题不存在
TOPIC_PARTITION_NOT_EXIST	分区不存在	451	分区不存在
CONSUMER_OPERATE_RESET_STRATEGY_INVALID_ERROR	消费组重置策略非法	451	CONSUMER_OPERATE_RESET_STRATEGY_INVALID_ERROR
INTERNAL_ERROR	服务内部错误	500	服务内部错误

请求示例

                Java
                
            

                POST http://kafka-api.bj.baidubce.com/v2/clusters/33a168bb70c0459787416077114ab233/consumer-groups/group-id-test/offsets
Authorization: bce-auth-v1/ALTAKaiKeDfBD880eMWBE5oIGE/2023-05-08T11:43:45Z/1800/host;x-bce-date/322f3f98ce57d296c0f5abc64e5554b640ea035c5cb462fcaeab54b9810a3c61
Host: kafka-api.bj.baidubce.com
  
{
	"topicName": "test",
	"partitions": [0, 1],
	"resetStrategy": "tolatest",
}
            

返回示例

                Java
                
            

                HTTP/1.1 200 OK
x-bce-request-id: 97e6d4ad-6fca-4609-ad4d-9a27c4d1a362
Date: Mon, 08 May 2023 09:39:11 GMT
Content-Type: application/json;charset=UTF-8
Server: BWS

{
    "groupName": "group-id-test"
}
            

查询消费组列表

查询消费组订阅的主题列表

百度智能云

消息服务 for Kafka

消息服务 for Kafka

重置消费组位点

请求结构

请求头域

请求参数

返回头域

返回参数

错误码

请求示例

返回示例