-
Notifications
You must be signed in to change notification settings - Fork 167
Description
I run "./PushConsumer“ fail after build example,but PullConsumer is ok. client log :
2019-01-18 17:31:35.315213:DefaultMQPushConsumer::boost asio async service runing
2019-01-18 17:31:35.317030:m_tcpConnectTimeout:400, m_tcpTransportTryLockTimeout:1, m_pullThreadNum:4
2019-01-18 17:31:35.317261:MQClient start,groupname:msg-persist-group_producer_sandbox,clientID:11113-fe80::f65d:28fe:7bfe:7546@DEFAULT,instanceName:DEFAULT,nameserveraddr:localhost:9876
2019-01-18 17:31:35.317323:DefaultMQProducer:msg-persist-group_producer_sandbox start
2019-01-18 17:31:35.317359:TcpRemotingClient::boost asio async service runing
2019-01-18 17:31:35.317389:update Namesrv:localhost:9876
2019-01-18 17:31:35.317633:user specfied name server address: localhost:9876
2019-01-18 17:31:35.317692:MQClientFactory:11113-fe80::f65d:28fe:7bfe:7546@DEFAULT start
2019-01-18 17:31:35.317841:sendheartbeat brokeradd is empty
2019-01-18 17:31:35.318023:start scheduled task:11113-fe80::f65d:28fe:7bfe:7546@DEFAULT
2019-01-18 17:31:35.318503:m_tcpConnectTimeout:400, m_tcpTransportTryLockTimeout:1, m_pullThreadNum:4
2019-01-18 17:31:35.318717:MQClient start,groupname:sdk,clientID:11113-fe80::f65d:28fe:7bfe:7546@sdk,instanceName:sdk,nameserveraddr:localhost:9876
2019-01-18 17:31:35.318777:TcpRemotingClient::boost asio async service runing
2019-01-18 17:31:35.318777:DefaultMQPushConsumer:sdk start
2019-01-18 17:31:35.319011:start concurrently consume service:sdk
2019-01-18 17:31:35.320613:buildSubscriptionData,:sdktesting,*
2019-01-18 17:31:35.320714:update Namesrv:localhost:9876
2019-01-18 17:31:35.320748:user specfied name server address: localhost:9876
2019-01-18 17:31:35.320776:MQClientFactory:11113-fe80::f65d:28fe:7bfe:7546@sdk start
2019-01-18 17:31:35.320866:updateTopicRouteInfoFromNameServer start:%RETRY%sdk
2019-01-18 17:31:35.321093:start scheduled task:11113-fe80::f65d:28fe:7bfe:7546@sdk
2019-01-18 17:31:35.321229:namesrvIndex is:1, index:0, namesrvaddrlist size:1
2019-01-18 17:31:35.321753:try to connect to fd:20, addr:127.0.0.1
2019-01-18 17:31:35.321929:Wait till event base is looping
2019-01-18 17:31:35.322036:Notify on event_base_dispatch
2019-01-18 17:31:35.322194:eventcb: received event:80 on fd:20
2019-01-18 17:31:35.322264:eventcb:connect to fd:20 successfully
2019-01-18 17:31:35.322310:received libevent callback event
2019-01-18 17:31:35.328046:sendheartbeat brokeradd is empty
2019-01-18 17:31:35.331145:sendheartbeat brokeradd is empty
2019-01-18 17:31:36.722216:connect timeout
2019-01-18 17:31:36.722389:connect server with addr:localhost:9876 success
2019-01-18 17:31:36.724738:updateTopicRouteInfoFromNameServer has data
2019-01-18 17:31:36.724905:updateTopicRouteInfoFromNameServer changed:%RETRY%sdk
2019-01-18 17:31:36.724944:updateTopicRouteInfoFromNameServer changed with broker name:TaoChen
2019-01-18 17:31:36.725128:updateTopicRouteInfoFromNameServer start:sdktesting
2019-01-18 17:31:36.727285:updateTopicRouteInfoFromNameServer has data
2019-01-18 17:31:36.727459:updateTopicRouteInfoFromNameServer changed:sdktesting
2019-01-18 17:31:36.727516:updateTopicRouteInfoFromNameServer changed with broker name:TaoChen
2019-01-18 17:31:36.728305:try to connect to fd:28, addr:10.8.64.103
2019-01-18 17:31:36.728513:Wait till event base is looping
2019-01-18 17:31:36.729229:Notify on event_base_dispatch
2019-01-18 17:31:36.729407:eventcb: received event:80 on fd:28
2019-01-18 17:31:36.729468:eventcb:connect to fd:28 successfully
2019-01-18 17:31:36.729513:received libevent callback event
2019-01-18 17:31:37.131392:connect timeout
2019-01-18 17:31:37.131564:connect server with addr:10.8.64.103:10911 success
2019-01-18 17:31:37.135192:notifyConsumerIdsChanged:sdk
2019-01-18 17:31:37.135263:sendheartbeat to broker:10.8.64.103:10911 success
2019-01-18 17:31:37.135375:Client factory:11113-fe80::f65d:28fe:7bfe:7546@sdk start dorebalance for consumer:sdk
2019-01-18 17:31:37.135453:Client factory:11113-fe80::f65d:28fe:7bfe:7546@sdk start dorebalance
2019-01-18 17:31:37.135497:current topic is:%RETRY%sdk
2019-01-18 17:31:37.135543:getConsumerIdList from broker:10.8.64.103:10911
2019-01-18 17:31:37.137827:client id:11113-fe80::f65d:28fe:7bfe:7546@sdk of topic:%RETRY%sdk
2019-01-18 17:31:37.137960:range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0
2019-01-18 17:31:37.138004:allocate mq:MessageQueue [topic=%RETRY%sdk, brokerName=TaoChen, queueId=0]
2019-01-18 17:31:37.138033:updateRequestTableInRebalance Doesn't find old mq
2019-01-18 17:31:37.140010:CONSUME_FROM_LAST_OFFSET, lastOffset of mq:MessageQueue [topic=%RETRY%sdk, brokerName=TaoChen, queueId=0] is:0
2019-01-18 17:31:37.140153:add mq:MessageQueue [topic=%RETRY%sdk, brokerName=TaoChen, queueId=0], request initiall offset:0
2019-01-18 17:31:37.140208:pullRequest with mq :MessageQueue [topic=%RETRY%sdk, brokerName=TaoChen, queueId=0] set pullMsgEvent
2019-01-18 17:31:37.140277:current topic is:sdktesting
2019-01-18 17:31:37.140336:getConsumerIdList from broker:10.8.64.103:10911
2019-01-18 17:31:37.140548:new pull callback for mq:MessageQueue [topic=%RETRY%sdk, brokerName=TaoChen, queueId=0]
2019-01-18 17:31:37.142611:client id:11113-fe80::f65d:28fe:7bfe:7546@sdk of topic:sdktesting
2019-01-18 17:31:37.142768:range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0
2019-01-18 17:31:37.142836:allocate mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=0]
2019-01-18 17:31:37.142885:allocate mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=1]
2019-01-18 17:31:37.142930:allocate mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=2]
2019-01-18 17:31:37.142975:allocate mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=3]
2019-01-18 17:31:37.143020:updateRequestTableInRebalance Doesn't find old mq
2019-01-18 17:31:37.145007:CONSUME_FROM_LAST_OFFSET, lastOffset of mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=0] is:0
2019-01-18 17:31:37.145110:add mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=0], request initiall offset:0
2019-01-18 17:31:37.145139:updateRequestTableInRebalance Doesn't find old mq
2019-01-18 17:31:37.146870:CONSUME_FROM_LAST_OFFSET, lastOffset of mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=1] is:0
2019-01-18 17:31:37.146958:add mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=1], request initiall offset:0
2019-01-18 17:31:37.146988:updateRequestTableInRebalance Doesn't find old mq
2019-01-18 17:31:37.148753:CONSUME_FROM_LAST_OFFSET, lastOffset of mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=2] is:0
2019-01-18 17:31:37.148885:add mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=2], request initiall offset:0
2019-01-18 17:31:37.148918:updateRequestTableInRebalance Doesn't find old mq
2019-01-18 17:31:37.150613:CONSUME_FROM_LAST_OFFSET, lastOffset of mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=3] is:0
2019-01-18 17:31:37.150735:add mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=3], request initiall offset:0
2019-01-18 17:31:37.150780:pullRequest with mq :MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=0] set pullMsgEvent
2019-01-18 17:31:37.150835:pullRequest with mq :MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=1] set pullMsgEvent
2019-01-18 17:31:37.150869:pullRequest with mq :MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=2] set pullMsgEvent
2019-01-18 17:31:37.150921:pullRequest with mq :MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=3] set pullMsgEvent
2019-01-18 17:31:37.151077:current topic is:%RETRY%sdk
2019-01-18 17:31:37.151224:getConsumerIdList from broker:10.8.64.103:10911
2019-01-18 17:31:37.151070:new pull callback for mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=0]
2019-01-18 17:31:37.151416:new pull callback for mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=1]
2019-01-18 17:31:37.151613:new pull callback for mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=2]
2019-01-18 17:31:37.152059:new pull callback for mq:MessageQueue [topic=sdktesting, brokerName=TaoChen, queueId=3]
2019-01-18 17:31:37.154975:client id:11113-fe80::f65d:28fe:7bfe:7546@sdk of topic:%RETRY%sdk
2019-01-18 17:31:37.155199:range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0
2019-01-18 17:31:37.155294:allocate mq:MessageQueue [topic=%RETRY%sdk, brokerName=TaoChen, queueId=0]
2019-01-18 17:31:37.155368:current topic is:sdktesting
2019-01-18 17:31:37.155430:getConsumerIdList from broker:10.8.64.103:10911