如果消息订阅者需要改变当前的消费位置,重新消费,可以使用重置消费位点功能。
您在使用重置消费位点功能前,需要确保所有 Consumer 客户端都已停用,否则重置消费位点将不能生效。
云原生消息引擎目前支持两种方式重置消费位点:
云原生消息引擎目前支持两种维度的重置消费位点:
登录云原生消息引擎控制台。
在顶部菜单栏,选择目标项目和地域。
在左侧导航栏选择 BMQ 实例,单击目标实例名称,进入实例详情页面。
在实例详情页面选择 Group 管理页签,然后单击目标 Group 后方的重置消费位点。
在重置消费位点对话框,选择需要重置消费位点的 Topic,设置重置方式和相关配置,然后单击确定。
说明
您在使用重置消费位点功能前,需要确保所有 Consumer 客户端都已停用,否则重置消费位点将不能生效。
参数 | 说明 |
---|---|
Group | 当前 Group,不可编辑。 |
Topic | 需要重置消费位点的 Topic。 |
重置方式 | 选择重置消费位点的方式。
|
时间点 | 当选择根据时间点重置方式时,需要设置具体的时间点,将 Group 的消费位点重置到过去或者将来的某个时间点对应的位点,从该时间点开始消费消息。 |
基准位置 | 当选择根据消费位点重置方式时,需要重新选择基准位置,支持最早消费位点、当前消费位点和最近消费位点 3 个设置方式,请按需选择。 |
相对偏移量 | 当选择根据消费位点重置方式时,除重置消费基准位置外,还需要设置相对偏移量。 |
登录云原生消息引擎控制台。
在顶部菜单栏,选择目标项目和地域。
在左侧导航栏选择 BMQ 实例,单击目标实例名称,进入实例详情页面。
在实例详情页面选择 Group 管理页签,然后单击目标 Group 名称。
在 Consumer Group 详情页面,单击目标 Topic 后方的消费详情。
在消费详情面板的分区消息区域,选择目标分区,并单击该分区后方的重置消费位点。
在重置消费位点对话框,选择需要重置消费位点的 Topic,设置重置方式和相关配置,然后单击确定。
说明
您在使用重置消费位点功能前,需要确保所有 Consumer 客户端都已停用,否则重置消费位点将不能生效。
参数 | 说明 |
---|---|
Group | 当前 Group,不可编辑。 |
Topic | 需要重置消费位点的 Topic。 |
重置方式 | 选择重置消费位点的方式。
|
时间点 | 当选择根据时间点重置方式时,需要设置具体的时间点,将 Group 的消费位点重置到过去或者将来的某个时间点对应的位点,从该时间点开始消费消息。 说明 您指定的时间点,不可以早于系统提示的最早消费时间。 |
基准位置 | 当选择根据消费位点重置方式时,需要重新选择基准位置,支持最早消费位点、当前消费位点和最近消费位点 3 个设置方式,请按需选择。 |
相对偏移量 | 当选择根据消费位点重置方式时,除重置消费基准位置外,还需要设置相对偏移量。 |