Apache RocketMQ中我这边发了一条,但是这边dashboard显示两条,是不是dashboard这边显示有问题呀? arthas 抓包的日志也有,返回了“Find prepared transaction message failed”,store.log 也大量出现selectMappedBuffer request pos invalid日志https://github.com/apache/rocketmq/discussions/6954
根据您提供的信息,这些错误可能是由于以下原因导致的:
在发送消息时,消息没有被正确地写入到数据存储中,导致了消息回查。 在消费消息时,由于一些异常情况导致消息被丢失或者不完整,导致了消息回查。 可能存在一些消息在从数据存储中读取时,由于一些异常情况导致消息被丢失或者不完整,导致了消息回查。 建议检查以下问题:
检查消息队列的数据存储是否正常,是否存在数据丢失或者不完整的情况。 检查消息在发送和消费时是否正常工作,是否存在一些异常情况导致消息被丢失或者不完整。 检查数据存储中的一些日志信息,是否存在一些消息被回查但是没有被正确地写入到数据存储中的情况。
"Find prepared transaction message failed" 和 "selectMappedBuffer request pos invalid" 错误,可能是由于 RocketMQ 存储文件(commitlog)出现异常导致的。您可以检查一下 Broker 的磁盘空间,确认是否有足够的空间进行消息存储。
以dashboard为准,看你的描述,可以确定发送消息时发生了错误或重试机制导致重复发送了两次。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/