RocketMQrocket5.0在创建消息为延时,但是实际上是正常,actualMessageType=NORMAL, acceptMessageTypes=[DELAY],请问一下开源版本不支持啊?
消息类型通过命令行创建指定的
对于RocketMQ 5.0版本及其之前的开源版本,延时消息功能是不被支持的。只有阿里云RocketMQ专业版提供了延时消息的能力。
在开源版本中,消息发送时设置的延时时间将被忽略,消息会立即投递给消费者或存储在消息队列中等待消费。这意味着,尽管您在消息中设置了延时时间,但实际上消息会立即被消费者接收或存储,而不会按照预定的延时时间进行处理。
如果您需要使用延时消息功能,建议考虑升级到阿里云RocketMQ专业版,该版本提供了对延时消息的支持。通过使用专业版,您可以设置消息的延时时间,并确保消息在指定的延时后才被消费者接收或存储。
创建topic时是什么类型, 发送消息的类型要一样。
——此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/