lirong-Lee opened a new issue #345: URL: https://github.com/apache/rocketmq-client-cpp/issues/345
The re_dev version of MessageListenerOrderly cannot be used, I use example/OrderlyPushConsumer.cpp, but I can’t get the message, but I can get the message normally with OrderlyPushConsumer.cpp in the master version 2.1.0. Logs： [2021-02-01 14:23:22.427] [info] [thread@33404] - the consumer [myGroup] start beginning. [2021-02-01 14:23:22.427] [info] [thread@33404] - buildSubscriptionData: 321321, * [2021-02-01 14:23:22.485] [info] [thread@33404] - updateNameServerAddressList: [172.18.139.94:9876] [2021-02-01 14:23:22.485] [info] [thread@33404] - update Namesrv:172.18.139.94:9876 [2021-02-01 14:23:22.485] [info] [thread@33404] - user specified name server address: 172.18.139.94:9876 [2021-02-01 14:23:22.485] [info] [thread@33404] - Created new MQClientInstance for clientId:[fe80::5c03:7258:6b59:5e16@16236] [2021-02-01 14:23:22.485] [info] [thread@33404] - MQClientImpl start, clientId:fe80::5c03:7258:6b59:5e16@16236, real nameservAddr:172.18.139.94:9876; [2021-02-01 14:23:22.485] [info] [thread@33404] - start orderly consume service: myGroup [2021-02-01 14:23:22.488] [info] [thread@33404] - the client instance [fe80::5c03:7258:6b59:5e16@16236] is starting [2021-02-01 14:23:22.494] [info] [thread@33404] - tcpConnectTimeout:400, tcpTransportTryLockTimeout:1, pullThreadNums:4 [2021-02-01 14:23:22.496] [info] [thread@33404] - start scheduled task:fe80::5c03:7258:6b59:5e16@16236 [2021-02-01 14:23:22.500] [info] [thread@33404] - Try to start service thread:RebalanceService started:false lastThread:0x0 [2021-02-01 14:23:22.503] [info] [thread@33404] - the client instance [fe80::5c03:7258:6b59:5e16@16236] start OK [2021-02-01 14:23:22.503] [info] [thread@30244] - RebalanceService service started [2021-02-01 14:23:22.503] [info] [thread@33404] - the consumer [myGroup] start OK [2021-02-01 14:23:22.503] [info] [thread@33404] - namesrvIndex is:1, index:0, namesrvaddrlist size:1 [2021-02-01 14:23:22.503] [info] [thread@33404] - connect to 172.18.139.94:9876. [2021-02-01 14:23:22.508] [info] [thread@33404] - try to connect to fd:844, addr:172.18.139.94:9876 [2021-02-01 14:23:22.508] [info] [thread@17228] - eventcb: received event:0x80 on fd:844 [2021-02-01 14:23:22.508] [info] [thread@17228] - eventcb: connect to fd:844 successfully [2021-02-01 14:23:22.508] [info] [thread@33404] - connect server with addr:172.18.139.94:9876 success [2021-02-01 14:23:22.509] [info] [thread@33404] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:22.509] [info] [thread@33404] - updateTopicRouteInfoFromNameServer changed:%RETRY%myGroup [2021-02-01 14:23:22.509] [info] [thread@33404] - updateTopicRouteInfoFromNameServer changed with broker name:broker-a [2021-02-01 14:23:22.511] [info] [thread@33404] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:22.511] [info] [thread@33404] - updateTopicRouteInfoFromNameServer changed:321321 [2021-02-01 14:23:22.511] [info] [thread@33404] - updateTopicRouteInfoFromNameServer changed with broker name:broker-a [2021-02-01 14:23:22.512] [info] [thread@33404] - connect to 172.18.139.94:10911. [2021-02-01 14:23:22.513] [info] [thread@33404] - try to connect to fd:872, addr:172.18.139.94:10911 [2021-02-01 14:23:22.513] [info] [thread@17228] - eventcb: received event:0x80 on fd:872 [2021-02-01 14:23:22.513] [info] [thread@17228] - eventcb: connect to fd:872 successfully [2021-02-01 14:23:22.513] [info] [thread@33404] - connect server with addr:172.18.139.94:10911 success [2021-02-01 14:23:22.514] [info] [thread@18556] - notifyConsumerIdsChanged, group:myGroup [2021-02-01 14:23:22.514] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:23:22.514] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:23:22.514] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:23:22.515] [info] [thread@33404] - connect to 172.18.139.124:10922. [2021-02-01 14:23:22.516] [info] [thread@33404] - try to connect to fd:884, addr:172.18.139.124:10922 [2021-02-01 14:23:22.516] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:23:22.516] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:23:22.516] [info] [thread@17228] - eventcb: received event:0x80 on fd:884 [2021-02-01 14:23:22.516] [info] [thread@17228] - eventcb: connect to fd:884 successfully [2021-02-01 14:23:22.516] [info] [thread@33404] - connect server with addr:172.18.139.124:10922 success [2021-02-01 14:23:22.517] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:23:22.517] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:23:22.517] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:23:22.517] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:23:22.518] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:23:22.518] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:23:22.519] [info] [thread@34772] - notifyConsumerIdsChanged, group:myGroup [2021-02-01 14:23:22.520] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:23:22.520] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:23:22.521] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:23:22.521] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=1], because lock failed [2021-02-01 14:23:22.523] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:23:22.523] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=2], because lock failed [2021-02-01 14:23:22.524] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:23:22.524] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=3], because lock failed [2021-02-01 14:23:22.524] [info] [thread@30244] - the client instance [fe80::5c03:7258:6b59:5e16@16236] finish doRebalance [2021-02-01 14:23:22.524] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:23:22.524] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:23:22.524] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:23:22.526] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:23:22.526] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:23:22.527] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:23:22.527] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:23:22.527] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:23:22.527] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:23:22.528] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:23:22.529] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:23:22.530] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:23:22.530] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:23:22.532] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:23:22.532] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=1], because lock failed [2021-02-01 14:23:22.533] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:23:22.533] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=2], because lock failed [2021-02-01 14:23:22.534] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:23:22.534] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=3], because lock failed [2021-02-01 14:23:22.535] [info] [thread@30244] - the client instance [fe80::5c03:7258:6b59:5e16@16236] finish doRebalance [2021-02-01 14:23:22.536] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:22.538] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:22.539] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:22.539] [info] [thread@32676] - updateTopicRouteInfoFromNameServer changed:TBW102 [2021-02-01 14:23:22.539] [info] [thread@32676] - updateTopicRouteInfoFromNameServer changed with broker name:broker-a [2021-02-01 14:23:42.509] [info] [thread@31088] - LockAll 0 broker mqs [2021-02-01 14:23:42.536] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:23:42.536] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:23:42.536] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:23:42.538] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:23:42.538] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:23:42.540] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:23:42.540] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:23:42.540] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:23:42.540] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:23:42.542] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:23:42.542] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:23:42.545] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:23:42.545] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:23:42.546] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:23:42.546] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=1], because lock failed [2021-02-01 14:23:42.549] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:23:42.549] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=2], because lock failed [2021-02-01 14:23:42.551] [error] [thread@30244] - the message queue locked Failed, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:23:42.551] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=3], because lock failed [2021-02-01 14:23:42.551] [info] [thread@30244] - the client instance [fe80::5c03:7258:6b59:5e16@16236] finish doRebalance [2021-02-01 14:23:52.555] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:52.557] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:23:52.558] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:24:02.522] [info] [thread@31088] - LockAll 0 broker mqs [2021-02-01 14:24:02.555] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:24:02.555] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:24:02.555] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:24:02.557] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:24:02.557] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:24:02.558] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:24:02.558] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:24:02.558] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:24:02.558] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:24:02.558] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:24:02.560] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:24:02.560] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:24:02.561] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:24:02.561] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:24:02.561] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:24:02.563] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:24:02.563] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:24:02.563] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=1], because lock failed [2021-02-01 14:24:02.566] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:24:02.566] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:24:02.566] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=2], because lock failed [2021-02-01 14:24:02.568] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:24:02.568] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:24:02.568] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=3], because lock failed [2021-02-01 14:24:02.569] [info] [thread@30244] - the client instance [fe80::5c03:7258:6b59:5e16@16236] finish doRebalance [2021-02-01 14:24:22.533] [info] [thread@31088] - LockAll 0 broker mqs [2021-02-01 14:24:22.569] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:24:22.569] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:24:22.569] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:24:22.570] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:24:22.570] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:24:22.572] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:24:22.572] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:24:22.572] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:24:22.572] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:24:22.572] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:24:22.574] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:24:22.574] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:24:22.576] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:24:22.576] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:24:22.576] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:24:22.578] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:24:22.578] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:24:22.578] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=1], because lock failed [2021-02-01 14:24:22.580] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:24:22.580] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:24:22.580] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=2], because lock failed [2021-02-01 14:24:22.581] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:24:22.581] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:24:22.581] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=3], because lock failed [2021-02-01 14:24:22.582] [info] [thread@30244] - the client instance [fe80::5c03:7258:6b59:5e16@16236] finish doRebalance [2021-02-01 14:24:22.583] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:24:22.585] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:24:22.586] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:24:42.543] [info] [thread@31088] - LockAll 0 broker mqs [2021-02-01 14:24:42.583] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:24:42.583] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:24:42.583] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:24:42.585] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:24:42.585] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:24:42.587] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:24:42.587] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:24:42.587] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:24:42.587] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:24:42.587] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:24:42.589] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:24:42.589] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:24:42.590] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:24:42.590] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] [2021-02-01 14:24:42.590] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:24:42.592] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:24:42.592] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=1] [2021-02-01 14:24:42.592] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=1], because lock failed [2021-02-01 14:24:42.593] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:24:42.593] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=2] [2021-02-01 14:24:42.593] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=2], because lock failed [2021-02-01 14:24:42.595] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:24:42.595] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=321321, brokerName=broker-a, queueId=3] [2021-02-01 14:24:42.595] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=321321, brokerName=broker-a, queueId=3], because lock failed [2021-02-01 14:24:42.595] [info] [thread@30244] - the client instance [fe80::5c03:7258:6b59:5e16@16236] finish doRebalance [2021-02-01 14:24:52.600] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:24:52.602] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:24:52.604] [info] [thread@32676] - updateTopicRouteInfoFromNameServer has data [2021-02-01 14:25:02.554] [info] [thread@31088] - LockAll 0 broker mqs [2021-02-01 14:25:02.596] [info] [thread@30244] - the client instance:fe80::5c03:7258:6b59:5e16@16236 start doRebalance [2021-02-01 14:25:02.596] [info] [thread@30244] - current topic is:%RETRY%myGroup [2021-02-01 14:25:02.596] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:25:02.598] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:%RETRY%myGroup [2021-02-01 14:25:02.598] [info] [thread@30244] - range is:1, index is:0, mqAllSize is:1, averageSize is:1, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:25:02.599] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:25:02.599] [warning] [thread@30244] - the message queue locked OK, but it is released, mq:MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0] [2021-02-01 14:25:02.599] [warning] [thread@30244] - doRebalance, myGroup, add a new mq failed, MessageQueue [topic=%RETRY%myGroup, brokerName=broker-a, queueId=0], because lock failed [2021-02-01 14:25:02.599] [info] [thread@30244] - current topic is:321321 [2021-02-01 14:25:02.599] [info] [thread@30244] - getConsumerIdList from broker:172.18.139.94:10911 [2021-02-01 14:25:02.600] [info] [thread@30244] - client id:fe80::5c03:7258:6b59:5e16@16236 of topic:321321 [2021-02-01 14:25:02.600] [info] [thread@30244] - range is:4, index is:0, mqAllSize is:4, averageSize is:4, startIndex is:0 [rocketmq::AllocateMQAveragely::allocate:69] [2021-02-01 14:25:02.602] [info] [thread@30244] - LockBatchResponseBody MQ:MessageQueue [topic=321321, brokerName=broker-a, queueId=0] ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
