问题一:rocketmq死信队列如果发送并消费成功,那么死信队列中的消息是会被标记已消费吗?
有没有从代码层面上处理rocketmq 死信队列的经验,比如根据 group 获取死信队列中的消息,再重新发送该消息,如果发送并消费成功,那么死信队列中的消息是会被标记已消费吗? 有没有案例哦?
参考答案:
你要消费死信队列里的消息,需要先修改消息的读写权限。然后把消息给移出去,你才能消费。移出的消息在死信看不到的。你要先查,再重新发送到原Topic中。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/616618
问题二:RocketMQ这个问题怎么处理?
https://github.com/apache/rocketmq-clients/issues/713
RocketMQ这个问题怎么处理?
参考答案:
1.你本地可以检查下3点1. 在proxy上使用arthas抓包, 看看返回的queue对不对
2.client打开debug日志,看看客户端请求的proxy地址是多少
3.普通消息走的这个逻辑, 本地debug看看是不是有bug
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/616617
问题三:RocketMQ这个broker的共享内存是和持久化的文件(例如CommitLog)有关吗?
RocketMQ随着生产消费过程进行,broker进程的SHR共享内存一直在增大,这个broker的共享内存是和持久化的文件(例如CommitLog)有关吗? 若当持久化文件以及过期消息 清理了 这个SHR共享内存会降下去吗?
参考答案:
会的。 rocketmq里面是通过map来将文件映射到进程的共享内存里面的,可以监控下变化,默认应该是1G1G的增减的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/616615
问题四:RocketMQ重试次数是不是就要应用方控制?
RocketMQ每次重置reconsumeTimes好像就达不到死信阈值了,这样的话重试次数是不是就要应用方控制?
参考答案:
是的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/616614
问题五:RocketMQ我想只针对某一个topic中的消息重试时间间隔调整为30s,怎么操作?
RocketMQ我想只针对某一个topic中的消息重试时间间隔调整为30s,怎么操作?
参考答案:
可以尝试一下在处理消息失败的时候始终 setReconsumeTimes = 0 , 验证一下,不保证一定可行。
关于本问题的更多回答可点击进行查看: