为了给业务处理业务失败,给消息消费失败的情况兜底,保证消息生命周期的完整,RocketMQ 实现了消费失败后重试的策略。
如果您使用的是 RocketMQ 4.x 客户端,消息的重试次数以您在客户端内设置消息重试次数为准。
对于 RocketMQ 5.x 集群,您在创建 Group 时可以设置消息的重试次数,如果您使用的是 5.x 客户端,则重试次数以您在服务端设定的为准;如果您使用的是 4.x 客户端,则充实次数依旧以客户端内设置消息重试次数为准。
操作场景
当您需要查看某个 Topic 下是否有重试消息时,您可以在 重试消息查询页 查询消息,并且可以展开查看消息每次重试的时间和生产者地址等信息,并且支持导出消息和查看消息的详细内容,如下图所示。 操作步骤
1. 登录 RocketMQ 控制台,在左侧导航栏单击 重试消息查询页。 2. 在消息查询页面,选择好地域后根据页面提示输入查询条件。
时间范围:选择需要查询的时间范围,支持近30分钟,近1小时,近6小时,近24小时,近3天和自定义时间范围。
集群:选择需要查询的 Topic 所在的集群。
Topic:选择需要查询的 Topic。
Group:如果查询的集群为 5.x 集群,则需要选择该 Topic 下订阅的具体 Group。4.x 集群无需填写。
查询方式:消息查询功能支持以下查询方式。
查询全部:该方式适合在对于重试消息的信息不明确的情况下使用,用于查询当前 Topic 下的全部重试消息。
按消息 ID 查询:该方式属于精确查询、速度快、精确匹配。
按消息 Key 查询:该方式属于模糊查询,适用于您没有记录消息 ID 但是设置了消息 Key 的场景。
说明:
为了保证查询速度,当您选择 “查询全部” 时,服务端会按照时间先后查询最近的消息,但由于查询时间和展示的限制,可能无法快速定位到您需要排查的消息。建议您使用更加明确的搜索条件,如 消息 ID 和消息 Key。
3. 单击查询,下方列表会展示所有查询到的结果并分页展示。
4. 查询完成后,您可以点击单条消息,查看当前消息的重试情况,如重试的次数和生产者地址等信息。您也可以单击操作栏的其他操作选项。
本页内容是否解决了您的问题?