SparkStreaming下Python报net.jpountz.lz4.LZ4BlockInputStream的解决
SparkStreaming下Python报net.jpountz.lz4.LZ4BlockInputStream的解决-Python 技术分享 Java技术分享 Python 爬虫技术_微信公众号:zeropython—昊天博客

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

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

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

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

修改了wordcount例子就可以了:

调用命令:

最后终于解决了

HTTPX 基础教程-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客