阿里云 Kafka 重置消费的位点(offset)
可以在阿里云后台的 Group 管理 → Group 详情 页通过点击右上角的 重置消费位点 来重置。
可以重置所有的 Topic ,也可以重置指定的 Topic 。
可以重置到当前最新位点(用于忽略堆积的消息),也可以重置到指定时间的位点。
Note
Topic 中消息的保留时间可以在 kafka 实例详情页修改 消息保留时长 属性。
注意
重置时必须关闭当前 Group 所有正在运行的消费者,否则会报 assignments can only be reset if the consumer id is inactive 的错误消息。
json
{
"request": {
"action": "ConsoleSubscriptionResetOffset",
"params": {
"RegionId": "cn-shanghai",
"PreventCache": 1629429205191,
"Dauth_url_hash": "",
"Collina": "",
"Csrf": "",
"instanceId": "alikafka_post-cn-instanceId",
"topic": "topic",
"consumerId": "consumerId",
"timestamp": 1628955800000,
"beginTime": 1628955800000
}
},
"response": {
"RequestId": "FE2906FB-5DF9-54DF-A44E-4386AFF0B5AC",
"Message": "assignments can only be reset if the consumer id is inactive",
"Recommend": "https://error-center.aliyun.com/status/search?Keyword=-2502&source=PopGw",
"HostId": "alikafkanext-share.cn-shanghai.aliyuncs.com",
"Code": "-2502"
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24