开发者社区> 问答> 正文

Demo Consumer能从RocketMq读取到数据,但在调用Kyro序列化时出问题

你好,我们在运行demo的producer将数据积压到RocketMq后,在运行Consumer时也能读到消息,在RocketMq的服务器上使用控制台输出时也能输出数据。但是,在调用RaceUtils.readKryoObject()函数时,函数不返回结果,但Consumer还是能继续获取下一条消息。于是我们在RaceUtils.readKryoObject()函数加了两条输入语句如下:


在Consumer运行时,能看到第一条输出语句"1.bytes.length:"的输出,但是看不到第二条输出语句。请问是什么问题呢?

展开
收起
jensontan 2016-06-26 23:36:22 5737 0
1 条回答
写回答
取消 提交回答
  • I like to program and write stuff, making things a reality always make me excited. Now, I am a Apache committer.
    可以debug进去看看readObject有什么异常。。
    2016-06-27 18:34:55
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载