阿里云 Kafka 重置消费的位点（offset）

🏷️ 阿里云 Kafka

可以在阿里云后台的 Group 管理 → Group 详情 页通过点击右上角的 重置消费位点 来重置。

可以重置所有的 Topic ，也可以重置指定的 Topic 。
可以重置到当前最新位点（用于忽略堆积的消息），也可以重置到指定时间的位点。

Note

Topic 中消息的保留时间可以在 kafka 实例详情页修改 消息保留时长 属性。

注意

重置时必须关闭当前 Group 所有正在运行的消费者，否则会报 assignments can only be reset if the consumer id is inactive 的错误消息。

{
    "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"
    }
}