开发者社区> 问答> 正文

为什么没有从Mq中收到结束消息呢?

比赛数据规范中说,会在消息生产结束时向三个 Topic 发送一条特殊消息,该消息的消息体为一个为 0 的 short,我按照Demo写的,在Consumer中判断获取结束消息的方法,但获取不到消息,不知道为什么呢?我确定其他常规的消息都接收到了。

展开
收起
solar007 2016-07-01 14:27:51 4649 0
4 条回答
写回答
取消 提交回答
  • https://bbs.aliyun.com/read/286971.html?spm=5176.bbsl254.0.0.5pPaRb

    -------------------------

    试跑阶段我给你数据是200万订单数据,你自己看下

    2016-07-01 22:34:27
    赞同 展开评论 打赏
  • Re为什么没有从Mq中收到结束消息呢?
    我也没收到
    2016-07-01 21:19:51
    赞同 展开评论 打赏
  • 回 1楼尘央的帖子
    我用LOG打印了,日志文件中确实没收到这条信息,不知道为什么?LOG肯定是没错的~

    -------------------------

    回 4楼玄弟的帖子
    我已经接收到了其他正常的MQ消息,而且把最终的结果写到了tair中,现在的正确率被14%多,就是没有接收到结尾消息,有没有可能是因为20分钟内,还没有把MQ消费完?
    2016-07-01 20:05:00
    赞同 展开评论 打赏
  • I like to program and write stuff, making things a reality always make me excited. Now, I am a Apache committer.
      你是怎么知道没有收到这条消息的。通过sout打印出来吗? 用Log.info到日志中看看吧。
    2016-07-01 17:43:49
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Rocket MQ 使用排查指南 立即下载
消息队列kafka介绍 立即下载
低代码开发师(初级)实战教程 立即下载