在此之前我看过两个issue:apache/rocketmq-spring#243 和 #1901 他们说降级为4.6.0不会发生此错误,我没有进行尝试,我rocketmq版本是4.8.0,依然存在CODE: 10007 property[CLUSTER] is null.错误,而且没有找到设置CLUSTER的地方,希望予以修复!
2021/2/6日补充: 降级4.6.0后此bug消失,没有尝试4.7.0版本,但是测试仍然4.8.0版本存在此bug
环境: IDEA 2020.2 rocketmq 4.8.0 rocketmq-spring-boot-starter 2.2.0
根据官网的示例代码,生产消息之后,等待回复,消费者进行消费,消费者可以获取到消息内容,但是回复时候报错如下
org.apache.rocketmq.client.exception.MQClientException: CODE: 10007 DESC: create reply message fail, requestMessage error, property[CLUSTER] is null. For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ at org.apache.rocketmq.client.utils.MessageUtil.createReplyMessage(MessageUtil.java:46) ~[rocketmq-client-4.8.0.jar:4.8.0] at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.handleMessage(DefaultRocketMQListenerContainer.java:399) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0] at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.access$100(DefaultRocketMQListenerContainer.java:70) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0] at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer$DefaultMessageListenerConcurrently.consumeMessage(DefaultRocketMQListenerContainer.java:354) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0] at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:412) [rocketmq-client-4.8.0.jar:4.8.0] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_77] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_77] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_77] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_77] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_77]
原提问者GitHub用户lengyue-ck
我用rockemq4.8.0作为服务端,用rocketmq-spring-boot-starter 2.2.0作为客户端进行测试,并没有复现该问题。
之前的问题在4.7.1被修复。所以1.确认下是否正确连接到4.8.0的服务端2.该问题是偶发还是必现的。
原回答者GitHub用户RongtongJin
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。