阿里云消息队列 Kafka 版重置消费位点

前提条件

已停止所有 Consumer 客户端（消息队列 Kafka 版不支持在线重置消费位点）。

注意 在停止 Consumer 客户端后，需要经过 ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG 配置的时间（默认 10000 毫秒），服务端才认为 Consumer 真正下线。

操作步骤

1. 登录消息队列 Kafka 版控制台。在顶部导航栏，选择实例所在的地域（Region），如华东1（杭州）。

2. 在左侧导航栏，单击Consumer Group管理 。

3. 在 Consumer Group管理页面的搜索框中输入 Consumer Group 名称, 然后单击搜索。

4. 在 Consumer Group管理页面的相应 Consumer Group 的操作列，单击重置消费位点。

5. 在弹出的对话框中选择您要采用的重置策略，然后单击确认。

   重置策略有以下两个可选项：

   • 清除所有堆积消息，从最新位点开始消费：对应本文开头介绍的消息清除功能

   • 按时间点进行消费位点重置：对应本文开头介绍的指定时间点开始消费功能（若选择此项，需选择时间点）