You need to enable JavaScript to run this app.
导航
重置消费位点
最近更新时间:2024.06.28 18:54:07首次发布时间:2023.01.19 17:01:15

如果消息订阅者需要改变当前的消费位置,重新消费,可以使用重置消费位点功能。

前提条件

您在使用重置消费位点功能前,需要确保所有 Consumer 客户端都已停用,否则重置消费位点将不能生效。

背景信息

云原生消息引擎目前支持两种方式重置消费位点:

  • 支持指定时间点,直接跳转到该时间点的位点开始消费消息。
  • 支持重新选择基准消费位置和相对偏移量,重新开始消费。

云原生消息引擎目前支持两种维度的重置消费位点:

  • 重置 Topic 的消费位点:针对 Topic 级别进行重置消费位点操作。
  • 重置分区的消费位点:针对 Topic 中某个分区进行重置消费位点操作。

重置 Topic 的消费位点

  1. 登录云原生消息引擎控制台

  2. 在顶部菜单栏,选择目标项目和地域。

  3. 在左侧导航栏选择 BMQ 实例,单击目标实例名称,进入实例详情页面。

  4. 在实例详情页面选择 Group 管理页签,然后单击目标 Group 后方的重置消费位点

  5. 重置消费位点对话框,选择需要重置消费位点的 Topic,设置重置方式和相关配置,然后单击确定

    说明

    您在使用重置消费位点功能前,需要确保所有 Consumer 客户端都已停用,否则重置消费位点将不能生效。

    图片

    参数

    说明

    Group

    当前 Group,不可编辑。

    Topic

    需要重置消费位点的 Topic。

    重置方式

    选择重置消费位点的方式。

    • 根据时间点:从指定时间点对应的位点开始消费消息。
    • 根据消费位点:从新的消费位点开始消费消息。

    时间点

    当选择根据时间点重置方式时,需要设置具体的时间点,将 Group 的消费位点重置到过去或者将来的某个时间点对应的位点,从该时间点开始消费消息。

    基准位置

    当选择根据消费位点重置方式时,需要重新选择基准位置,支持最早消费位点当前消费位点最近消费位点 3 个设置方式,请按需选择。

    相对偏移量

    当选择根据消费位点重置方式时,除重置消费基准位置外,还需要设置相对偏移量。
    如果重置后的消费位置大于或小于 offset 取值范围,那么消费位点将会定位至最大或最小值。

重置分区的消费位点

  1. 登录云原生消息引擎控制台

  2. 在顶部菜单栏,选择目标项目和地域。

  3. 在左侧导航栏选择 BMQ 实例,单击目标实例名称,进入实例详情页面。

  4. 在实例详情页面选择 Group 管理页签,然后单击目标 Group 名称。

  5. 在 Consumer Group 详情页面,单击目标 Topic 后方的消费详情
    图片

  6. 消费详情面板的分区消息区域,选择目标分区,并单击该分区后方的重置消费位点
    图片

  7. 重置消费位点对话框,选择需要重置消费位点的 Topic,设置重置方式和相关配置,然后单击确定

    说明

    您在使用重置消费位点功能前,需要确保所有 Consumer 客户端都已停用,否则重置消费位点将不能生效。

    图片

    参数

    说明

    Group

    当前 Group,不可编辑。

    Topic

    需要重置消费位点的 Topic。

    重置方式

    选择重置消费位点的方式。

    • 根据时间点:从指定时间点对应的位点开始消费消息。
    • 根据消费位点:从新的消费位点开始消费消息。

    时间点

    当选择根据时间点重置方式时,需要设置具体的时间点,将 Group 的消费位点重置到过去或者将来的某个时间点对应的位点,从该时间点开始消费消息。

    说明

    您指定的时间点,不可以早于系统提示的最早消费时间。

    基准位置

    当选择根据消费位点重置方式时,需要重新选择基准位置,支持最早消费位点当前消费位点最近消费位点 3 个设置方式,请按需选择。

    相对偏移量

    当选择根据消费位点重置方式时,除重置消费基准位置外,还需要设置相对偏移量。
    如果重置后的消费位置大于或小于 offset 取值范围,那么消费位点将会定位至最大或最小值。