Hi,

I follow http://rocketmq.apache.org/docs/quick-start/ to setup RocketMQ and 
test message sending.


Environment:


# cat /etc/redhat-release 
Red Hat Enterprise Linux Server release 7.4 (Maipo)
# java -version
java version "1.8.0_65"
Java(TM) SE Runtime Environment (build 1.8.0_65-b17)
Java HotSpot(TM) 64-Bit Server VM (build 25.65-b01, mixed mode)



RocketMQ Version: 4.2.0


1. Create Topic
# bin/mqadmin updateTopic -b localhost:10911 -c DefaultCluster -n 
172.24.150.158:9876 -t TopicTest 


# bin/mqadmin topicRoute -t TopicTest -n 172.24.150.158:9876
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; 
support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; 
support was removed in 8.0
{
        "brokerDatas":[
                {
                        "brokerAddrs":{0:"172.24.150.159:10911"
                        },
                        "brokerName":"i-B6712B6C",
                        "cluster":"DefaultCluster"
                }
        ],
        "filterServerTable":{},
        "queueDatas":[
                {
                        "brokerName":"i-B6712B6C",
                        "perm":6,
                        "readQueueNums":8,
                        "topicSynFlag":0,
                        "writeQueueNums":8
                }
        ]
}



2. try send message, told no route info


# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; 
support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; 
support was removed in 8.0
15:14:34.726 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the 
default logging framework
15:14:34.733 [main] DEBUG i.n.c.MultithreadEventLoopGroup - 
-Dio.netty.eventLoopThreads: 4
15:14:34.745 [main] DEBUG i.n.util.internal.PlatformDependent0 - 
java.nio.Buffer.address: available
15:14:34.746 [main] DEBUG i.n.util.internal.PlatformDependent0 - 
sun.misc.Unsafe.theUnsafe: available
15:14:34.747 [main] DEBUG i.n.util.internal.PlatformDependent0 - 
sun.misc.Unsafe.copyMemory: available
15:14:34.747 [main] DEBUG i.n.util.internal.PlatformDependent0 - direct buffer 
constructor: available
15:14:34.748 [main] DEBUG i.n.util.internal.PlatformDependent0 - 
java.nio.Bits.unaligned: available, true
15:14:34.748 [main] DEBUG i.n.util.internal.PlatformDependent0 - 
java.nio.DirectByteBuffer.<init>(long, int): available
15:14:34.749 [main] DEBUG io.netty.util.internal.Cleaner0 - 
java.nio.ByteBuffer.cleaner(): available
15:14:34.749 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8
15:14:34.750 [main] DEBUG i.n.util.internal.PlatformDependent - 
-Dio.netty.noUnsafe: false
15:14:34.750 [main] DEBUG i.n.util.internal.PlatformDependent - 
sun.misc.Unsafe: available
15:14:34.750 [main] DEBUG i.n.util.internal.PlatformDependent - 
-Dio.netty.noJavassist: false
15:14:34.837 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: 
available
15:14:34.837 [main] DEBUG i.n.util.internal.PlatformDependent - 
-Dio.netty.tmpdir: /tmp (java.io.tmpdir)
15:14:34.838 [main] DEBUG i.n.util.internal.PlatformDependent - 
-Dio.netty.bitMode: 64 (sun.arch.data.model)
15:14:34.838 [main] DEBUG i.n.util.internal.PlatformDependent - 
-Dio.netty.noPreferDirect: false
15:14:34.838 [main] DEBUG i.n.util.internal.PlatformDependent - 
io.netty.maxDirectMemory: 1040187392 bytes
15:14:34.849 [main] DEBUG io.netty.channel.nio.NioEventLoop - 
-Dio.netty.noKeySetOptimization: false
15:14:34.850 [main] DEBUG io.netty.channel.nio.NioEventLoop - 
-Dio.netty.selectorAutoRebuildThreshold: 512
15:14:34.853 [main] DEBUG i.n.util.internal.PlatformDependent - 
org.jctools-core.MpscChunkedArrayQueue: available
org.apache.rocketmq.client.exception.MQClientException: No route info of this 
topic, TopicTest
See http://rocketmq.apache.org/docs/faq/ for further details.
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:564)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1069)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1023)
        at 
org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
        at 
org.apache.rocketmq.example.quickstart.Producer.main(Producer.java:67)
org.apache.rocketmq.client.exception.MQClientException: No route info of this 
topic, TopicTest
See http://rocketmq.apache.org/docs/faq/ for further details.
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:564)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1069)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1023)
        at 
org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
        at 
org.apache.rocketmq.example.quickstart.Producer.main(Producer.java:67)

Reply via email to