使用消息队列 RocketMQ 版后消息未到预期客户端,怎么办?
阿里云提醒您: 如果您对实例或数据有修改、变更等风险操作,务必注意实例的容灾、容错能力,确保数据安全。 如果您对实例(包括但不限于ECS、RDS)等进行配置与数据修改,建议提前创建快照或开启RDS日志备份等功能。 如果您在阿里云平台授权或者提交过登录账号、密码等安全信息,建议您及时修改。 登录代码所在服务器,根据连接状态定位有问题的进程,然后通过/XXX/logs/ons.log文件以及代码查看配置的AccessKeyId、AccessKeySecret、Topic等信息,如不正确则进行修改。 若问题暂时无法解决,可以先关闭有问题的客户端进程,此时之前堆积的消息会立马进行调整,投递至正常的客户端,待定位的问题修复后,再重启有问题的进程。 执行以上步骤后需要进行结果验证。登录消息队列 RocketMQ 控制台,依次选择 Group 管理 > 消费者状态,在连接信息栏中,确认所有已连接的客户端IP地址都在预期范围内,并能正常消费消息,同时确认订阅关系是否一致显示 是。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/