更新时间:2024-09-20 GMT+08:00

验证RocketMQ消息消费

消费验证是将消息重新发送到指定的在线客户端,验证消费者能否收到消息。消费验证会导致消息重复消费。

前提条件

  • 仅在实例的“状态”为“运行中”时,才可以进行消费验证。
  • 确保待进行消费验证的客户端处于在线状态,且消费者已订阅待重新发送的消息所属的Topic。

验证RocketMQ消息消费

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择RocketMQ实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。
  4. 单击RocketMQ实例的名称,进入实例详情页面。
  5. 在左侧导航栏,单击“消息查询”,进入“消息查询”页面。
  6. 在页面顶部设置查询条件,查询待重新发送的消息。
  7. 在待重新发送的消息所在行,单击“消费验证”,弹出“消费验证”对话框。
  8. 参考表1,设置消费验证参数。

    表1 消费验证参数说明

    参数

    说明

    Group ID

    选择待进行消费验证的消费组名称。

    客户端 ID

    选择待进行消费验证的客户端ID。

    图1 消费验证

  9. 单击“确定”。

    消息重新发送成功后,“消费验证”对话框顶部会显示“消费验证成功”,此时客户端中会收到重新发送的消息。

    消费验证会导致消息重复消费。