lengyue-ck opened a new issue #2660:
URL: https://github.com/apache/rocketmq/issues/2660


   在此之前我看过两个issue:https://github.com/apache/rocketmq-spring/issues/243https://github.com/apache/rocketmq/issues/1901,他们说降级为4.6.0不会发生此错误,我没有进行尝试,我rocketmq版本是4.8.0,依然存在CODE:
 10007  property[CLUSTER] is null.错误,而且没有找到设置CLUSTER的地方,希望予以修复!
   
   环境:
   IDEA 2020.2
   rocketmq 4.8.0
   rocketmq-spring-boot-starter 2.0.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]
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to