RocketMQ死信
我在dashboard上点重发,没有重发,还报错,各位遇到过这个问题吗?用mqadmin querymsgbyid去根据msgid查,也查不到这条message。
RocketMQ的死信是指消息在消费端无法成功消费,并且超过了设置的延迟时间,此时消息会被标记为死信。对于你遇到的问题,可能有以下几种情况:
消费端程序出现问题,导致消息无法成功消费。这种情况下,你需要检查消费端的代码,看看是否有异常抛出或者逻辑错误。
RocketMQ的配置问题。你可能需要检查RocketMQ的配置,特别是关于死信的消息的处理策略。默认情况下,RocketMQ会将死信的消息重新发送到队列中,由其他消费者进行消费。但是,如果你配置了将死信的消息直接删除,那么就无法通过mqadmin命令查询到这些消息。
RocketMQ的服务器出现问题。如果RocketMQ的服务器出现故障,可能会导致消息无法正确处理。这种情况下,你需要检查RocketMQ服务器的日志,看看是否有异常信息。
对于你的问题,我建议你首先检查消费端的代码,然后检查RocketMQ的配置,最后检查RocketMQ服务器的日志。
在RocketMQ中,如果在dashboard上点重发,没有重发,还报错,可能是由于以下原因:
如果使用mqadmin querymsgbyid去根据msgid查,也查不到这条message,可能是由于以下原因:
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/