我向主题a发送了一条调度消息,该消息被设置为在32分钟后调度,并希望消息被消费。12小时后,它仍然存储在主题“schedule_topic_XXXX”中,没有加载到主题a。代理服务、namesrv、消费者客户端工作良好,尚未重新启动。日程表消息总是很有效,这是第一次发生。
以下是从store.log中获得的信息
2021-08-03 08:57:20 INFO pool-1-thread-1 - MessageExt:MessageExt [queueId=1, storeSize=693, queueOffset=346354, sysFlag=0, bornTimestamp=1627952240718, bornHost=/17.168.16.18:26936, storeTimestamp=1627952240719, storeHost=/17.168.17.57:10911, msgId=11A8113900002A9F00000003C8C16C2A, commitLogOffset=16253021226, bodyCRC=52349613, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='SCHEDULE_TOPIC_XXXX', flag=0, properties={traceId=4cb7e5d847fdff2ff9c8ebe0d31c13cf, REAL_TOPIC=ZCY_ZEUS_AUTO_OPEN_DECRYPT_MESSAGE_prod-shanxi, KEYS=6820553202238516087, __STARTDELIVERTIME=__STARTDELIVERTIME_ZMQ, UNIQ_KEY=0A652219000149C2FAAE0C38AC4E004C, DELAY=1959, WAIT=false, TAGS=null, REAL_QID=5}, body=[**message body **], transactionId='null'}], startIndex:346355,phyOffset:16253021226,bufferSize:693
通过queryMsgById在2021-08-03 20:28从主题“SCHEDULE_topic_XXXX”中查询
在2021-08-03 20:30通过queryMsgByUniqueKey从主题“A”进行查询
version:4.5.0
原提问者GitHub用户xuxiping2014
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
你们是有改过messageDelayLevel延迟策略嘛,能延迟32分钟并且在SCHEDULE_TOPIC_XXXX的队列1里面 同时也可以看下store.log里面是否有ScheduleMessageService相关的异常日志信息
原回答者GitHub用户panzhi33
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。