SparkStreaming下Python报net.jpountz.lz4.LZ4BlockInputStream的解决
SparkStreaming下Python报net.jpountz.lz4.LZ4BlockInputStream的解决-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客

这几天在测试SparkStreaming,连接Kafka一直报这个错,

连接同事用java写进去的都OK,用client端或NiFi都抱着个错.

开始一直怀疑jar包版本的问题, 用了最新的spark-streaming-kafka-0-8-assembly_2.10-2.2.2.jar 也是出错.

最后查到这个文档,设置这个参数就可以了:

修改了wordcount例子就可以了:

调用命令:

最后终于解决了