热线电话:13121318867

登录
2019-06-21 阅读量: 768
Spark Streaming 和kafka整合后读取消息

问题:Spark Streaming 和kafka整合后读取消息报错:OffsetOutOfRangeException

解决方案:如果和kafka消息中间件结合使用,请检查消息体是否大于默认设置1m,如果大于,则需要设置fetch.message.max.bytes=1m,这里需要把值设置大些

100.0000
1
关注作者
收藏
评论(0)

发表评论

暂无数据
推荐帖子