问题背景:
在进行Spark Streaming对接Kafka,采用Direct方式的时候,StringDecoder要导入kafka.serializer.StringDecoder,怎么也导入不进去,
手动添加导入serializer就报红!!!
解决:
import _root_.kafka.serializer.StringDecoder
OK~~~
在进行Spark Streaming对接Kafka,采用Direct方式的时候,StringDecoder要导入kafka.serializer.StringDecoder,怎么也导入不进去,
手动添加导入serializer就报红!!!
import _root_.kafka.serializer.StringDecoder
OK~~~