You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/12/18 13:14:55 UTC
[GitHub] [rocketmq] junqingzh commented on issue #2660: Code: 10007 Property [CLUSTER] is null
junqingzh commented on issue #2660:
URL: https://github.com/apache/rocketmq/issues/2660#issuecomment-997201161
broker 用 ： rocketmq-all-4.9.2-bin-release.zip
运行 官网的示例代码，example/rpc
mvn exec:java -Dexec.mainClass="org.apache.rocketmq.example.rpc.ResponseConsumer"
Consumer Started.
mvn exec:java -Dexec.mainClass="org.apache.rocketmq.example.rpc.RequestProducer"
生产消息之后，等待回复，3秒后超时报异常：
RocketMQLog:WARN Please initialize the logger system properly.
org.apache.rocketmq.client.exception.RequestTimeoutException: CODE: 10006 DESC: send request message to <RequestTopic> OK, but wait reply message timeout, 3000 ms.
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.waitResponse(DefaultMQProducerImpl.java:1543)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.request(DefaultMQProducerImpl.java:1419)
at org.apache.rocketmq.client.producer.DefaultMQProducer.request(DefaultMQProducer.java:600)
at org.apache.rocketmq.example.rpc.RequestProducer.main(RequestProducer.java:40)
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:254)
at java.lang.Thread.run(Thread.java:748)
过了好半天，
消费者获取到消息内容，但是回复时候报错如下:
ConsumeMessageThread_1 Receive New Messages: [MessageExt [brokerName=broker-b, queueId=2, storeSize=275, queueOffset=0, sysFlag=0, bornTimestamp=1639832919532, bornHost=/192.168.3.212:58578, storeTimestamp=1639832919591, storeHost=/10.106.161.8:10911, msgId=0A6AA10800002A9F00000002519EC36E, commitLogOffset=9959293806, bodyCRC=198614610, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='RequestTopic', flag=0, properties={MIN_OFFSET=0, REPLY_TO_CLIENT=10.10.1.52@11852#322394473677153, MAX_OFFSET=1, CONSUME_START_TIME=1639832947679, UNIQ_KEY=7F0000012E4C23D8E7965C1599EB0000, WAIT=true, TTL=3000, CORRELATION_ID=8456100b-a9d5-4d7a-9860-dc9f887b985f}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}]]
handle message: MessageExt [brokerName=broker-b, queueId=2, storeSize=275, queueOffset=0, sysFlag=0, bornTimestamp=1639832919532, bornHost=/192.168.3.212:58578, storeTimestamp=1639832919591, storeHost=/10.106.161.8:10911, msgId=0A6AA10800002A9F00000002519EC36E, commitLogOffset=9959293806, bodyCRC=198614610, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='RequestTopic', flag=0, properties={MIN_OFFSET=0, REPLY_TO_CLIENT=10.10.1.52@11852#322394473677153, MAX_OFFSET=1, CONSUME_START_TIME=1639832947679, UNIQ_KEY=7F0000012E4C23D8E7965C1599EB0000, WAIT=true, TTL=3000, CORRELATION_ID=8456100b-a9d5-4d7a-9860-dc9f887b985f}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}]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)
at org.apache.rocketmq.example.rpc.ResponseConsumer$1.consumeMessage(ResponseConsumer.java:63)
at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:392)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
我的环境为 双主集群， 但是在单主集群尝试，问题仍旧。
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org