apache / rocketmq-client-python

Apache RocketMQ python client
https://rocketmq.apache.org/
Apache License 2.0
271 stars 95 forks source link

Question:How to set instance_id when I connect Aliyun RocketMQ? #121

Open designer-app opened 2 years ago

designer-app commented 2 years ago

I am using rocketmq-client-python 2.0.0. Lib rocketmq-client-cpp-2.0.0.amd64.deb is install. But when I try to connect Aliyun RocketMQ, producer will throw exception and found the instanceName : DEFAULT. Is this problem because of the instance_id not set correctly? How set this?

2022-Jan-19 08:33:23.690079:m_tcpConnectTimeout:3000, m_tcpTransportTryLockTimeout:3, m_pullThreadNum:12[TcpRemotingClient:61] 2022-Jan-19 08:33:23.690300:MQClient start,groupname:nlp-team-faq,clientID:307-10.2.2.82@DEFAULT,instanceName:DEFAULT,nameserveraddr:MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080[start:141] 2022-Jan-19 08:33:23.690321:DefaultMQProducer:nlp-team-faq start[start:69] 2022-Jan-19 08:33:23.690337:updateNameServerAddressList: [MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080][updateNameServerAddressList:123] 2022-Jan-19 08:33:23.690351:update Namesrv:MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080[updateNameServerAddressList:148] 2022-Jan-19 08:33:23.690311:TcpRemotingClient::boost asio async service running[boost_asio_work:67] 2022-Jan-19 08:33:23.690369:user specfied name server address: MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080[registerProducer:332] 2022-Jan-19 08:33:23.690391:MQClientFactory:307-10.2.2.82@DEFAULT start[start:68] 2022-Jan-19 08:33:23.690432:sendheartbeat brokeradd is empty[sendHeartbeatToAllBroker:703] 2022-Jan-19 08:33:23.690477:start scheduled task:307-10.2.2.82@DEFAULT[startScheduledTask:803] 2022-Jan-19 08:33:23.690514:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.690594:namesrvIndex is:1, index:0, namesrvaddrlist size:1[CreateNameServerTransport:379] 2022-Jan-19 08:33:23.698658:try to connect to fd:15, addr:MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com[connect:172] 2022-Jan-19 08:33:23.699732:eventcb: received event:80 on fd:15[eventCallback:191] 2022-Jan-19 08:33:23.699773:eventcb: connect to fd:15 successfully[eventCallback:193] 2022-Jan-19 08:33:23.699800:connect server with addr:MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080 success[CreateTransport:348] 2022-Jan-19 08:33:23.700630:sendheartbeat brokeradd is empty[sendHeartbeatToAllBroker:703] 2022-Jan-19 08:33:23.708156:updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141] 2022-Jan-19 08:33:23.708181:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.710422:tryToFindTopicPublishInfo null:faq-unload-skill[tryToFindTopicPublishInfo:146] 2022-Jan-19 08:33:23.710445:Retry many times, still failed[sendDefaultImpl:376] 2022-Jan-19 08:33:23.710459:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.712650:updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141] 2022-Jan-19 08:33:23.712686:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.714880:tryToFindTopicPublishInfo null:faq-unload-skill[tryToFindTopicPublishInfo:146] 2022-Jan-19 08:33:23.714903:Retry many times, still failed[sendDefaultImpl:376] 2022-Jan-19 08:33:23.714915:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.717132:updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141] 2022-Jan-19 08:33:23.717153:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.719354:tryToFindTopicPublishInfo null:faq-unload-skill[tryToFindTopicPublishInfo:146] 2022-Jan-19 08:33:23.719372:Retry many times, still failed[sendDefaultImpl:376] 2022-Jan-19 08:33:23.719382:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.721564:updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141] 2022-Jan-19 08:33:23.721588:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.723755:tryToFindTopicPublishInfo null:faq-unload-skill[tryToFindTopicPublishInfo:146] 2022-Jan-19 08:33:23.723770:Retry many times, still failed[sendDefaultImpl:376] 2022-Jan-19 08:33:23.723781:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.725950:updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141] 2022-Jan-19 08:33:23.725967:updateTopicRouteInfoFromNameServer start:faq-unload-skill[updateTopicRouteInfoFromNameServer:159] 2022-Jan-19 08:33:23.728121:tryToFindTopicPublishInfo null:faq-unload-skill[tryToFindTopicPublishInfo:146] 2022-Jan-19 08:33:23.728140:Retry many times, still failed[sendDefaultImpl:376] 2022-Jan-19 08:33:23.728219:msg: No route info of this topic: faq-unload-skill,error:-1,in file </tmp/rocketmq-client-cpp/src/producer/DefaultMQProducer.cpp> line:379[send:115] 2022-Jan-19 08:33:23.731921:DefaultMQProducer shutdown[shutdown:96] 2022-Jan-19 08:33:23.732073:disconnect:MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080 start. event:0x562a4adc12a0[disconnect:132] 2022-Jan-19 08:33:23.732100:disconnect:MQ_INST_xxxxxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080 completely[disconnect:135] 2022-Jan-19 08:33:23.732389:TcpRemotingClient::stopAllTcpTransportThread End, m_tcpTable:0[stopAllTcpTransportThread:119] 2022-Jan-19 08:33:23.732408:MQClientFactory:307-10.2.2.82@DEFAULT shutdown[shutdown:298] 2022-Jan-19 08:33:23.732418:MQClientFactory:307-10.2.2.82@DEFAULT destruct[~MQClientFactory:50]