最近用Spark Streaming从Kafka接数据进行处理，是对中文的内容进行计算。发现处理时中文全变成了????????的形式，导致处理的结果和预期的不一样。但把数据放在redis或者放入下游的kafka topic，中文又正常了。为了防止是因为打日志的编码问题导致的判断出错，专门对算法进行了判断，的确就是对?????的东西处理了，而不是原中文字符串。 最近用Spark Streaming从Kafka接数据进行处理，是对中文的内容进行计算
阅读背景：
Spark Streaming 处理中文异常的解决方案
来源：互联网
分享到：
