zoukankan      html  css  js  c++  java
  • RECONSUME_LATER

    Failure consumption,later try to consume.

    ================MessageExt [queueId=0, storeSize=134, queueOffset=2, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224186835, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F0000000000983278, commitLogOffset=9974392, bodyCRC=212786421, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={TAGS=MyTag, WAIT=true, MAX_OFFSET=3, MIN_OFFSET=0}, body=15]]

    ================MessageExt [queueId=0, storeSize=274, queueOffset=2, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224196880, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F000000000098340D, commitLogOffset=9974797, bodyCRC=212786421, reconsumeTimes=1, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=3, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=3, MIN_OFFSET=0, REAL_QID=0}, body=15]]

    ================MessageExt [queueId=0, storeSize=274, queueOffset=3, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224227381, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F000000000098362E, commitLogOffset=9975342, bodyCRC=212786421, reconsumeTimes=2, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=4, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=4, MIN_OFFSET=0, REAL_QID=0}, body=15]]

    ================MessageExt [queueId=0, storeSize=274, queueOffset=4, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224287440, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F000000000098384F, commitLogOffset=9975887, bodyCRC=212786421, reconsumeTimes=3, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=5, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=5, MIN_OFFSET=0, REAL_QID=0}, body=15]]

    ================MessageExt [queueId=0, storeSize=274, queueOffset=5, sysFlag=0, bornTimestamp=1442224189878, bornHost=/172.16.10.103:41609, storeTimestamp=1442224407558, storeHost=/172.16.50.62:10911, msgId=AC10323E00002A9F0000000000983A70, commitLogOffset=9976432, bodyCRC=212786421, reconsumeTimes=4, preparedTransactionOffset=0, toString()=Message [topic=MyTopic, flag=0, properties={DELAY=6, ORIGIN_MESSAGE_ID=AC10323E00002A9F0000000000983278, REAL_TOPIC=%RETRY%MyConsumerGroup, TAGS=MyTag, WAIT=false, RETRY_TOPIC=MyTopic, MAX_OFFSET=6, MIN_OFFSET=0, REAL_QID=0}, body=15]]

  • 相关阅读:
    thinkphp 前台输出
    php的四种定界符
    面试总结
    Git分布式版本控制工具
    Apache Dubbo
    Mybatis03
    Mybatis02
    Mybaitis01
    linux下如何安装webbench
    SpringUtil
  • 原文地址:https://www.cnblogs.com/zno2/p/4807852.html
Copyright © 2011-2022 走看看