apache / apache/rocketmq-client-cpp
received duplicate messages, branch: master
- Vorherrschende Sprache
- C++
- Sterne
- 393
- Forks
- 167
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beschreibung
the duplicated message id: 0A64F892048A1B9871B45B0C6972005C
[2021-Dec-18 16:19:00.037053](info):processResponseCommand, code:11, opaque:1028, maxRetryTimes:1, retrySendTimes:1[processResponseCommand:520]
[2021-Dec-18 16:19:00.037081](info):cancelTimerCallback: opaque:1028[cancelTimerCallback:625]
[2021-Dec-18 16:19:00.037153](info):handleAsyncRequestTimeout aborted opaque:1028, e_code:125, msg:操作已取消[handleAsyncRequestTimeout:538]
[2021-Dec-18 16:19:00.037315](info):incConsumeRT before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:13608, Count: 1[incConsumeRT:103]
[2021-Dec-18 16:19:00.037352](info):incConsumeRT After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:13608, Count: 1[incConsumeRT:113]
[2021-Dec-18 16:19:00.037385](info):PullRequest: putMessage m_queueOffsetMax:3025 [putMessage:66]
[2021-Dec-18 16:19:00.037470](info):FOUND:MessageQueue [topic=zhujiuyin_async_topic, brokerName=RaftNode04, queueId=4] with size:1, nextBeginOffset:3026[onSuccess:88]
[2021-Dec-18 16:19:00.037159](info):code:0, language:JAVA, version:393, opaque:1027, flag:1, remark:FOUND, headLen:219, bodyLen:338 [Decode:177]
[2021-Dec-18 16:19:00.037514](info):=====Receive Messages,Topic[zhujiuyin_async_topic], MsgId[0A64F892048A1B9871B45B0C6972005C],Body[{"app_name": "server", "script_name": "crontab_check_rocketmq_lag", "param": null, "log_tag": null}],RetryTimes[0][ConsumeRequest:179]
[2021-Dec-18 16:19:00.037572](info):find_response opaque:1027[ProcessData:507]
[2021-Dec-18 16:19:00.037610](info):processResponseCommand, code:11, opaque:1027, maxRetryTimes:1, retrySendTimes:1[processResponseCommand:520]
[2021-Dec-18 16:19:00.037631](info):cancelTimerCallback: opaque:1027[cancelTimerCallback:625]
[2021-Dec-18 16:19:00.037685](info):code:0, language:JAVA, version:393, opaque:1029, flag:1, remark:FOUND, headLen:219, bodyLen:338 [Decode:177]
[2021-Dec-18 16:19:00.037717](info):find_response opaque:1029[ProcessData:507]
[2021-Dec-18 16:19:00.037739](info):processResponseCommand, code:11, opaque:1029, maxRetryTimes:1, retrySendTimes:1[processResponseCommand:520]
[2021-Dec-18 16:19:00.037757](info):cancelTimerCallback: opaque:1029[cancelTimerCallback:625]
[2021-Dec-18 16:19:00.037862](info):incConsumeRT before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:13608, Count: 1[incConsumeRT:103]
[2021-Dec-18 16:19:00.037897](info):incConsumeRT After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:27216, Count: 2[incConsumeRT:113]
[2021-Dec-18 16:19:00.037931](info):PullRequest: putMessage m_queueOffsetMax:3025 [putMessage:66]
[2021-Dec-18 16:19:00.037984](info):FOUND:MessageQueue [topic=zhujiuyin_async_topic, brokerName=RaftNode04, queueId=4] with size:1, nextBeginOffset:3026[onSuccess:88]
[2021-Dec-18 16:19:00.038067](info):incConsumeRT before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:13609, Count: 1[incConsumeRT:103]
[2021-Dec-18 16:19:00.038102](info):incConsumeRT After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:40825, Count: 3[incConsumeRT:113]
[2021-Dec-18 16:19:00.038126](info):PullRequest: putMessage m_queueOffsetMax:3025 [putMessage:66]
[2021-Dec-18 16:19:00.038163](info):FOUND:MessageQueue [topic=zhujiuyin_async_topic, brokerName=RaftNode04, queueId=4] with size:1, nextBeginOffset:3026[onSuccess:88]
[2021-Dec-18 16:19:00.038242](info):handleAsyncRequestTimeout aborted opaque:1027, e_code:125, msg:操作已取消[handleAsyncRequestTimeout:538]
[2021-Dec-18 16:19:00.038274](info):handleAsyncRequestTimeout aborted opaque:1029, e_code:125, msg:操作已取消[handleAsyncRequestTimeout:538]
[2021-Dec-18 16:19:00.038413](info):before insert declared filed,MAP SIZE is:2[doBeforeRequest:43]
[2021-Dec-18 16:19:00.038454](info):after insert declared filed, MAP SIZE is:12[doBeforeRequest:47]
[2021-Dec-18 16:19:00.038473](info):total msg info are:qadeptRMQ3025zhujiuyin_async_consumer32430261639814925133*150007zhujiuyin_async_topic, size is:75[doBeforeRequest:63]
[2021-Dec-18 16:19:00.038643](info):invokeAsync success, addr:xx.xx.xx.xx:50911, code:11, opaque:1037[invokeAsync:265]
[2021-Dec-18 16:19:00.038715](info):before insert declared filed,MAP SIZE is:2[doBeforeRequest:43]
[2021-Dec-18 16:19:00.038748](info):after insert declared filed, MAP SIZE is:12[doBeforeRequest:47]
[2021-Dec-18 16:19:00.038768](info):total msg info are:qadeptRMQ3025zhujiuyin_async_consumer32430261639814925133*150007zhujiuyin_async_topic, size is:75[doBeforeRequest:63]
[2021-Dec-18 16:19:00.038870](info):invokeAsync success, addr:xx.xx.xx.xx:50911, code:11, opaque:1038[invokeAsync:265]
[2021-Dec-18 16:19:00.038934](info):before insert declared filed,MAP SIZE is:2[doBeforeRequest:43]
[2021-Dec-18 16:19:00.038978](info):after insert declared filed, MAP SIZE is:12[doBeforeRequest:47]
[2021-Dec-18 16:19:00.039006](info):total msg info are:qadeptRMQ3025zhujiuyin_async_consumer32430261639814925133*150007zhujiuyin_async_topic, size is:75[doBeforeRequest:63]
[2021-Dec-18 16:19:00.039151](info):invokeAsync success, addr:xx.xx.xx.xx:50911, code:11, opaque:1039[invokeAsync:265]
[2021-Dec-18 16:19:00.079686](info):incConsumeRT before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:42, Count: 1[incConsumeRT:103]
[2021-Dec-18 16:19:00.079877](info):incConsumeRT After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:40867, Count: 4[incConsumeRT:113]
[2021-Dec-18 16:19:00.079912](info):incConsumeOKTPS Before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, Count: 1[incConsumeOKTPS:117]
[2021-Dec-18 16:19:00.079931](info):incConsumeOKTPS After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, Count: 1[incConsumeOKTPS:124]
[2021-Dec-18 16:19:00.079950](info):m_queueOffsetMax is:3025[removeMessage:111]
[2021-Dec-18 16:19:00.079979](info): offset result is:3026, m_queueOffsetMax is:3025, msgs size:1[removeMessage:115]
[2021-Dec-18 16:19:00.079998](info):remove these msg from m_msgTreeMap, its offset:3025[removeMessage:118]
[2021-Dec-18 16:19:00.080093](info):=====Receive Messages,Topic[zhujiuyin_async_topic], MsgId[0A64F892048A1B9871B45B0C6972005C],Body[{"app_name": "server", "script_name": "crontab_check_rocketmq_lag", "param": null, "log_tag": null}],RetryTimes[0][ConsumeRequest:179]
[2021-Dec-18 16:19:00.082514](info):incConsumeRT before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:2, Count: 1[incConsumeRT:103]
[2021-Dec-18 16:19:00.082592](info):incConsumeRT After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:40869, Count: 5[incConsumeRT:113]
[2021-Dec-18 16:19:00.082613](info):incConsumeOKTPS Before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, Count: 1[incConsumeOKTPS:117]
[2021-Dec-18 16:19:00.082630](info):incConsumeOKTPS After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, Count: 2[incConsumeOKTPS:124]
[2021-Dec-18 16:19:00.082647](info):m_queueOffsetMax is:3025[removeMessage:111]
[2021-Dec-18 16:19:00.082668](warning):Note: Get local offset for mq:MessageQueue [topic=zhujiuyin_async_topic, brokerName=RaftNode04, queueId=4] failed, may be it is updated before. skip..[ConsumeRequest:316]
[2021-Dec-18 16:19:00.082717](info):=====Receive Messages,Topic[zhujiuyin_async_topic], MsgId[0A64F892048A1B9871B45B0C6972005C],Body[{"app_name": "server", "script_name": "crontab_check_rocketmq_lag", "param": null, "log_tag": null}],RetryTimes[0][ConsumeRequest:179]
[2021-Dec-18 16:19:00.084563](info):incConsumeRT before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:2, Count: 1[incConsumeRT:103]
[2021-Dec-18 16:19:00.084614](info):incConsumeRT After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, RT:40871, Count: 6[incConsumeRT:113]
[2021-Dec-18 16:19:00.084635](info):incConsumeOKTPS Before Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, Count: 1[incConsumeOKTPS:117]
[2021-Dec-18 16:19:00.084651](info):incConsumeOKTPS After Key:zhujiuyin_async_topic@zhujiuyin_async_consumer, Count: 3[incConsumeOKTPS:124]
[2021-Dec-18 16:19:00.084668](info):m_queueOffsetMax is:3025[removeMessage:111]
[2021-Dec-18 16:19:00.084686](warning):Note: Get local offset for mq:MessageQueue [topic=zhujiuyin_async_topic, brokerName=RaftNode04, queueId=4] failed, may be it is updated before. skip..[ConsumeRequest:316]
[2021-Dec-18 16:19:00.201338](info):Client factory start persistAllConsumerOffset[persistAllConsumerOffset:811]
[2021-Dec-18 16:19:00.201573](info):oneway updateConsumeOffsetToBroker of mq:MessageQueue [topic=zhujiuyin_async_topic, brokerName=RaftNode04, queueId=4], its offset is:3026[updateConsumeOffsetToBroker:310]
[2021-Dec-18 16:19:00.201633](info):before insert declared filed,MAP SIZE is:2[doBeforeRequest:43]
[2021-Dec-18 16:19:00.201668](info):after insert declared filed, MAP SIZE is:6[doBeforeRequest:47]
[2021-Dec-18 16:19:00.201694](info):total msg info are:qadeptRMQ3026zhujiuyin_async_consumer4zhujiuyin_async_topic, size is:49[doBeforeRequest:63]
[2021-Dec-18 16:19:00.201919](info):invokeOneway success. addr:xx.xx.xx.xx:50911, code:15[invokeOneway:281]
[2021-Dec-18 16:19:00.202328](info):had received all data. msgLen:117, from:45, recvLen:121[readNextMessageIntCallback:262]
[2021-Dec-18 16:19:00.202429](info):too little data received with sum = 0[readNextMessageIntCallback:254]
[2021-Dec-18 16:19:00.202484](info):code:0, language:JAVA, version:393, opaque:1040, flag:1, remark:, headLen:113, bodyLen:0 [Decode:177]
[2021-Dec-18 16:19:00.202543](info):responseFuture was deleted by timeout of opaque:1040[ProcessData:502]
[2021-Dec-18 16:19:03.164889](info):had received all data. msgLen:291, from:24, recvLen:295[readNextMessageIntCallback:262]
[2021-Dec-18 16:19:03.165150](info):too little data received with sum = 0[readNextMessageIntCallback:254]
[2021-Dec-18 16:19:03.165265](info):code:307, language:JAVA, version:393, opaque:-591779724, flag:0, remark:, headLen:287, bodyLen:0 [Decode:177]
[2021-Dec-18 16:19:03.165430](info):request Command received:processRequest, addr::30911, code:307[processRequest:31]
[2021-Dec-18 16:19:03.165469](info):consumerGroup:zhujiuyin_async_consumer, clientId:65.22@1406#DEFAULT, jstackEnable:0[Decode:624]
[2021-Dec-18 16:19:03.165488](info):getConsumerRunningInfo:zhujiuyin_async_consumer[getConsumerRunningInfo:111]
[2021-Dec-18 16:19:03.165627](info):getConsumeStats Topic:%RETRY%zhujiuyin_async_consumer, Group:zhujiuyin_async_consumer[getConsumeStats:74]
[2021-Dec-18 16:19:03.165650](info):getConsumeStats Key:%RETRY%zhujiuyin_async_consumer@zhujiuyin_async_consumer[getConsumeStats:77]
[2021-Dec-18 16:19:03.165677](info):getConsumeStats Topic:zhujiuyin_async_topic, Group:zhujiuyin_async_consumer[getConsumeStats:74]
[2021-Dec-18 16:19:03.165693](info):getConsumeStats Key:zhujiuyin_async_topic@zhujiuyin_async_consumer[getConsumeStats:77]
[2021-Dec-18 16:19:03.165899](info):before insert declared filed,MAP SIZE is:2[doBeforeRequest:43]
Beitragsleitfaden
Bewertung
Dieses Issue wurde noch nicht bewertet.