重置订阅组消费进度到指定时间戳
更新时间 2025-11-27 16:35:44
最近更新时间: 2025-11-27 16:35:44
接口功能介绍
重置订阅组消费进度到指定时间戳
接口约束
无
URI
POST /v3/consumer/resetOffset
路径参数 无
Query参数 无
请求参数
请求头header参数
| 参数 | 是否必填 | 参数类型 | 说明 | 示例 | 下级对象 |
|---|---|---|---|---|---|
| regionId | 是 | String | 资源池编码 | 200000002368 |
请求体body参数
| 参数 | 是否必填 | 参数类型 | 说明 | 示例 | 下级对象 |
|---|---|---|---|---|---|
| prodInstId | 是 | String | 实例ID | ||
| groupName | 是 | String | 订阅组名字 | ||
| topicName | 是 | String | Topic名字 | ||
| resetTime | 是 | Long | 要重置的毫秒时间戳 |
响应参数
| 参数 | 参数类型 | 说明 | 示例 | 下级对象 |
|---|---|---|---|---|
| statusCode | String | 接口系统层面状态码。成功：800，失败：900 | ||
| message | String | 描述状态 | ||
| returnObj | String | 返回对象 | returnObj | |
| error | String | 错误码，只有非成功才有这个字段，方便快速定位问题 | 201 | |
| 表 returnObj |
| 参数 | 参数类型 | 说明 | 示例 | 下级对象 |
|---|---|---|---|---|
| total | Integer | 总记录数 | 4 | |
| diffOffset | Integer | 偏移量差值 | 5 | |
| rows | Array of Objects | 队列偏移量详情列表 | rows | |
| 表 rows |
| 参数 | 参数类型 | 说明 | 示例 | 下级对象 |
|---|---|---|---|---|
| brokerName | String | Broker名称 | mq_test_broker_1 | |
| queueId | Integer | 队列ID | 0 | |
| brokerOffset | Integer | Broker端偏移量 | 6 | |
| consumerOffset | Integer | 消费者端偏移量 | 6 | |
| timestampOffset | Integer | 时间戳偏移量 | 5 | |
| rollbackOffset | Integer | 回滚偏移量 | 5 |
枚举参数
无
请求示例
请求url
https://[endpoint].ctapi.ctyun.cn/v3/consumer/resetOffset
请求头header
无
请求体body
{
"prodInstId":"mq_test",
"groupName":"group",
"topicName":"test",
"resetTime":1661843664000
}
响应示例
响应成功示例
{
"returnObj":{
"total":4,
"diffOffset":5,
"rows":[
{
"brokerName":"mq_test_broker_1",
"queueId":0,
"brokerOffset":6,
"consumerOffset":6,
"timestampOffset":5,
"rollbackOffset":5
},
{
"brokerName":"mq_test_broker_1",
"queueId":1,
"brokerOffset":6,
"consumerOffset":6,
"timestampOffset":5,
"rollbackOffset":5
},
{
"brokerName":"mq_test_broker_1",
"queueId":2,
"brokerOffset":7,
"consumerOffset":7,
"timestampOffset":6,
"rollbackOffset":6
},
{
"brokerName":"mq_test_broker_1",
"queueId":3,
"brokerOffset":8,
"consumerOffset":8,
"timestampOffset":6,
"rollbackOffset":6
}
]
},
"message":"success",
"statusCode":800
}
响应失败示例
{
"returnObj": {},
"message": "...",
"error":"201",
"statusCode": "900"
}
状态码
请参考 状态码
错误码
请参考 错误码
