powerfulsnail opened a new issue #96: broker中某个队列不消费，什么情况会触发？ URL: https://github.com/apache/rocketmq-client-cpp/issues/96 场景：服务器A启动8个生产者不停的分别往8个不同的topic发送消息，同时服务器B启动8个不同group组的消费者不停的分别消费这8个topic，消费一段时间后出现某个队列中的消息不消费了，慢慢个别队列也停止消费。 出现[2019-Feb-23 23:52:51.464556](error):no response got for opaque:920486 [2019-Feb-23 23:52:51.464588](error):send msg, callback timeout, opaque:920486, sendTimes:1, maxRetryTimes:1错误后，broker-c, 的queueId=3这个队列就找不到了，即消费不到该队列中的消息。 日志： [2019-Feb-23 23:52:51.461848](debug):FOUND:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-c, queueId=3] with size:1, nextBeginOffset:171597 [2019-Feb-23 23:52:51.461897](debug): offset result is:171597, m_queueOffsetMax is:171596, msgs size:1 [2019-Feb-23 23:52:51.461932](debug):remove these msg from m_msgTreeMap, its offset:171596 [2019-Feb-23 23:52:51.461958](debug):pullMessageAsync set opaque:920485, mq:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-b, queueId=1] [2019-Feb-23 23:52:51.462000](debug):before insert declared filed,MAP SIZE is:2 [2019-Feb-23 23:52:51.462013](debug):invokeAsync success, addr:202.15.8.161:10911, code:11, opaque:920485 [2019-Feb-23 23:52:51.462057](debug):after insert declared filed, MAP SIZE is:12 [2019-Feb-23 23:52:51.462082](debug):total msg info are:ALIYUN171597groupaa0083231715971550934443954*150007MQ_TOPIC_EFC_DEVICE_STATUS, size is:77 [2019-Feb-23 23:52:51.462163](debug):pullMessageAsync set opaque:920486, mq:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-c, queueId=3] [2019-Feb-23 23:52:51.462207](debug):invokeAsync success, addr:202.15.8.162:10911, code:11, opaque:920486 [2019-Feb-23 23:52:51.463762](debug):fd:23, totalLen:453, bytesInMessage:449 [2019-Feb-23 23:52:51.463807](debug):had received all data with len:453 from fd:23 [2019-Feb-23 23:52:51.463829](debug):broker addr: 202.15.8.160, broker port: 10911 [2019-Feb-23 23:52:51.463849](debug):brokerAddr:202.15.8.160:10911 [2019-Feb-23 23:52:51.463872](debug): too little data received with sum = 0 [2019-Feb-23 23:52:51.463914](debug):code:0, remark:JAVA, version:277, opaque:920474, flag:1, remark:FOUND, headLen:226, bodyLen:219 [2019-Feb-23 23:52:51.463975](debug):processResponseCommand, code:11,opaque:920474, maxRetryTimes:1, retrySendTimes:1 [2019-Feb-23 23:52:51.464004](debug):cancelTimerCallback: opaque:920474 [2019-Feb-23 23:52:51.464044](debug):handleAsyncPullForResponseTimeout opaque:920474, e_code:0, msg:Success [2019-Feb-23 23:52:51.464057](debug):PullRequest: putMessage m_queueOffsetMax:163072 [2019-Feb-23 23:52:51.464136](debug):FOUND:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-a, queueId=0] with size:1, nextBeginOffset:163073 [2019-Feb-23 23:52:51.464158](debug):m_queueOffsetMax is:163072 [2019-Feb-23 23:52:51.464211](debug): offset result is:163073, m_queueOffsetMax is:163072, msgs size:1 [2019-Feb-23 23:52:51.464234](debug):remove these msg from m_msgTreeMap, its offset:163072 [2019-Feb-23 23:52:51.464277](debug):before insert declared filed,MAP SIZE is:2 [2019-Feb-23 23:52:51.464331](debug):after insert declared filed, MAP SIZE is:12 [2019-Feb-23 23:52:51.464352](debug):total msg info are:ALIYUN163072groupaa0083201630731550934443954*150007MQ_TOPIC_EFC_DEVICE_STATUS, size is:77 [2019-Feb-23 23:52:51.464434](debug):pullMessageAsync set opaque:920486, mq:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-a, queueId=0] [2019-Feb-23 23:52:51.464471](debug):addTimerCallback:erase timerCallback opaque:920486 [2019-Feb-23 23:52:51.464507](debug):handleAsyncPullForResponseTimeout opaque:920486, e_code:0, msg:Success [2019-Feb-23 23:52:51.464509](debug):invokeAsync success, addr:202.15.8.160:10911, code:11, opaque:920486 [2019-Feb-23 23:52:51.464556](error):no response got for opaque:920486 [2019-Feb-23 23:52:51.464588](error):send msg, callback timeout, opaque:920486, sendTimes:1, maxRetryTimes:1 [2019-Feb-23 23:52:51.464616](warning):pullrequest for:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-a, queueId=0] occurs exception, reproduce it [2019-Feb-23 23:52:51.464640](debug):eraseTimerCallback: opaque:920486 [2019-Feb-23 23:52:51.464669](debug):handleAsyncPullForResponseTimeout opaque:920486, e_code:0, msg:Success
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
