rocketmq-python
rocketmq-python copied to clipboard
messense
阿里云非ONSAddr接入方式
现在的阿里云RocketMQ新建示例已经不再使用ONSAddr接入方式，请问是否有办法支持新的接入方式
使用旧的实例中的ons接入方式是可以跑通的，使用新版的接入方式一直报No route info of this topic
Use set_namesrv_addr I think?
https://github.com/messense/rocketmq-python/blob/75d4ce47561884e338ae7abdd175a928e5e87711/rocketmq/client.py#L305
No effect in the newly created instance, and it raise "No route info of this topic"
Take a look at ~/logs/rocketmq-cpp/*.log and paste some logs here if you can.
Some logs here, replaced sensitive parameters like group_id as ${GROUP_ID}, and ignored some retry
[2019-Dec-02 16:42:34.463180](info):m_tcpConnectTimeout:3000, m_tcpTransportTryLockTimeout:3, m_pullThreadNum:8[TcpRemotingClient:61]
[2019-Dec-02 16:42:34.463346](info):MQClient start,groupname:${GROUP_ID},clientID:6442-${LOCAL_INTERNAL_IP}@DEFAULT,instanceName:DEFAULT,nameserveraddr:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080[start:141]
[2019-Dec-02 16:42:34.463372](info):DefaultMQProducer:${GROUP_ID} start[start:69]
[2019-Dec-02 16:42:34.463388](info):updateNameServerAddressList: [${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080][updateNameServerAddressList:123][2019-Dec-02 16:42:34.463356](info):TcpRemotingClient::boost asio async service running[boost_asio_work:67]
[2019-Dec-02 16:42:34.463404](info):update Namesrv:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080[updateNameServerAddressList:148]
[2019-Dec-02 16:42:34.463418](info):user specfied name server address: ${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080[registerProducer:332]
[2019-Dec-02 16:42:34.463429](info):MQClientFactory:6442-${LOCAL_INTERNAL_IP}@DEFAULT start[start:68]
[2019-Dec-02 16:42:34.463471](warning):sendheartbeat brokeradd is empty[sendHeartbeatToAllBroker:703]
[2019-Dec-02 16:42:34.463552](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.463571](info):start scheduled task:6442-${LOCAL_INTERNAL_IP}@DEFAULT[startScheduledTask:803]
[2019-Dec-02 16:42:34.463619](info):namesrvIndex is:1, index:0, namesrvaddrlist size:1[CreateNameServerTransport:379]
[2019-Dec-02 16:42:34.463861](info):try to connect to fd:15, addr:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com[connect:172]
[2019-Dec-02 16:42:34.473792](warning):sendheartbeat brokeradd is empty[sendHeartbeatToAllBroker:703]
[2019-Dec-02 16:42:34.490490](info):eventcb: received event:80 on fd:15[eventCallback:191]
[2019-Dec-02 16:42:34.490575](info):eventcb: connect to fd:15 successfully[eventCallback:193]
[2019-Dec-02 16:42:34.490630](info):connect server with addr:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080 success[CreateTransport:348]
[2019-Dec-02 16:42:34.517449](info):updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141]
[2019-Dec-02 16:42:34.517505](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.544419](warning):tryToFindTopicPublishInfo null:${MY_TOPIC}[tryToFindTopicPublishInfo:146]
[2019-Dec-02 16:42:34.544503](warning):Retry many times, still failed[sendDefaultImpl:376]
[2019-Dec-02 16:42:34.544520](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.571434](info):updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141]
[2019-Dec-02 16:42:34.571515](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.598445](warning):tryToFindTopicPublishInfo null:${MY_TOPIC}[tryToFindTopicPublishInfo:146]
[2019-Dec-02 16:42:34.598537](warning):Retry many times, still failed[sendDefaultImpl:376]
[2019-Dec-02 16:42:34.761287](error):msg: No route info of this topic: ${MY_TOPIC},error:-1,in file </tmp/rocketmq-client-cpp/src/producer/DefaultMQProducer.cpp> line:379[send:115]
[2019-Dec-02 16:42:34.764294](info):DefaultMQProducer shutdown[shutdown:96]
[2019-Dec-02 16:42:34.764478](info):disconnect:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080 start. event:0xf78e90[disconnect:132]
[2019-Dec-02 16:42:34.764526](info):disconnect:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080 completely[disconnect:135]
[2019-Dec-02 16:42:34.764748](error):TcpRemotingClient::stopAllTcpTransportThread End, m_tcpTable:0[stopAllTcpTransportThread:119]
[2019-Dec-02 16:42:34.764771](info):MQClientFactory:6442-${LOCAL_INTERNAL_IP}@DEFAULT shutdown[shutdown:298]
[2019-Dec-02 16:42:34.764784](info):MQClientFactory:6442-${LOCAL_INTERNAL_IP}@DEFAULT destruct[~MQClientFactory:50]
I tried it and it indeed raises No route info of this topic exception, the log isn't very helpful.
It might be a issue with https://github.com/apache/rocketmq-client-cpp , in the mean time you can try https://github.com/apache/rocketmq-client-python to see if it also suffers from this problem.