更新时间:2025-08-13 GMT+08:00
分享

验证RocketMQ消息消费

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

前提条件

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

验证RocketMQ消息消费

  1. 登录RocketMQ实例控制台
  2. 单击RocketMQ实例的名称,进入实例详情页面。
  3. 在左侧导航栏,单击“实例管理 > 消息查询”,进入“消息查询”页面。
  4. 在页面顶部设置查询条件,查询待重新发送的消息。
  5. 在待重新发送的消息所在行,单击“消费验证”,弹出“消费验证”对话框。
  6. 参考表1,设置消费验证参数。

    表1 消费验证参数说明

    参数

    说明

    Group ID

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

    客户端 ID

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

    图1 消费验证

  7. 单击“确定”。

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

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

相关文档

消费验证也可以通过调用API完成,具体请参见消费验证

相关文档