问题背景:
在进行Spark Streaming对接Kafka,采用Direct方式的时候,StringDecoder要导入kafka.serializer.StringDecoder,怎么也导入不进去,
![](https://img.haomeiwen.com/i8816575/f1c05563ee116a84.png)
手动添加导入serializer就报红!!!
![](https://img.haomeiwen.com/i8816575/c994e8de37e2901c.png)
解决:
import _root_.kafka.serializer.StringDecoder
OK~~~
在进行Spark Streaming对接Kafka,采用Direct方式的时候,StringDecoder要导入kafka.serializer.StringDecoder,怎么也导入不进去,
手动添加导入serializer就报红!!!
import _root_.kafka.serializer.StringDecoder
OK~~~
本文标题:解决:kafka.serializer.StringDecode
本文链接:https://www.haomeiwen.com/subject/kkqdsqtx.html
网友评论