I made mistake, when set namesrv env, use only ip, forgot port.
------------------ ???????? ------------------
??????: "????????????"<371887...@qq.com>;
????????: 2018??6??19??(??????) ????8:22
??????: "users"<users@rocketmq.apache.org>;
????: ?????? Quick Start: No route info of this topic, TopicTest
I will summary the issue. can anyone do me a favour ?
1. Auto create topic is enabled by default, not sure why topic is not create
automaticly when send message.
2. Create topic manually, told no route info. But check topic route info is
correct?
3. client log looks code throws exception.
2018-06-19 08:12:53 INFO MQClientFactoryScheduledThread - new name server is
chosen. OLD: 172.24.150.158 , NEW: 172.24.150.158. namesrvIndex = 68
2018-06-19 08:12:53 ERROR MQClientFactoryScheduledThread - createChannel:
create channel exception
java.lang.ArrayIndexOutOfBoundsException: 1
at
org.apache.rocketmq.remoting.common.RemotingHelper.string2SocketAddress(RemotingHelper.java:57)
~[rocketmq-remoting-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.createChannel(NettyRemotingClient.java:478)
[rocketmq-remoting-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateNameserverChannel(NettyRemotingClient.java:433)
[rocketmq-remoting-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateChannel(NettyRemotingClient.java:394)
[rocketmq-remoting-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:363)
[rocketmq-remoting-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1207)
[rocketmq-client-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1197)
[rocketmq-client-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:605)
[rocketmq-client-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:492)
[rocketmq-client-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:361)
[rocketmq-client-4.2.0.jar:4.2.0]
at
org.apache.rocketmq.client.impl.factory.MQClientInstance$3.run(MQClientInstance.java:278)
[rocketmq-client-4.2.0.jar:4.2.0]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[na:1.8.0_65]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[na:1.8.0_65]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_65]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_65]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_65]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_65]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_65]
------------------ ???????? ------------------
??????: "????????????"<371887...@qq.com>;
????????: 2018??6??19??(??????) ????8:02
??????: "??????"<1026203...@qq.com>;"users"<users@rocketmq.apache.org>;
????: ?????? Quick Start: No route info of this topic, TopicTest
Thanks.
1. auto create topic already true by default, but not sure why ask create topic
manually.
2. I already create topic before send message.
------------------ ???????? ------------------
??????: "??????"<1026203...@qq.com>;
????????: 2018??6??15??(??????) ????6:07
??????: "users"<users@rocketmq.apache.org>;
????: "????????"<371887...@qq.com>;
????: ?????? Quick Start: No route info of this topic, TopicTest
try those
1. set auto create topic when start broker
or
2. create topic first, then try send messages
------------------
Have a nice dayFrancis Lee
QQ : 1026203200
