【求意见】如何使用spark streaming接收kafka中发送的自定义对象？

Cherise 发表于 2015-5-29 14:40:10 [显示全部楼层] 只看大图回帖奖励

阅读模式关闭右栏 10 69191

Cherise 发表于 2015-6-1 12:12:15

问题解决了，使用文章http://www.iteblog.com/archives/1296中提到的“用ByteArrayOutputStream并结合ObjectOutputStream类将对象转换成Byte数组；并用ByteArrayInputStream结合ObjectInputStream类将Byte数组转换回对象”方法替换了SerializationUtils.serialize和SerializationUtils.deserialize，可以正常接收对象并进行解码了

使用道具举报