2019-06-21
阅读量:
768
Spark Streaming 和kafka整合后读取消息
问题:Spark Streaming 和kafka整合后读取消息报错:OffsetOutOfRangeException
解决方案:如果和kafka消息中间件结合使用,请检查消息体是否大于默认设置1m,如果大于,则需要设置fetch.message.max.bytes=1m,这里需要把值设置大些






评论(0)


暂无数据
推荐帖子
0条评论
1条评论
0条评论