SparkStream从kafka读取数据编码问题(Java)_kafkaread设置编码-CSDN博客

网站介绍:文章浏览阅读6.6k次。SparkStreaming从kafka读取文件流时(Java),默认是utf-8的,如果源文件的编码不是utf-8,那就会出现乱码现象,但是kafka的官网参数里没有关于编码的参数,不过kafka的源码里面是有的。源码如下:publicvoidconfigure(Mapconfigs,booleanisKey){StringpropertyName=isKey?"key.seri_kafkaread设置编码