我正在尝试添加一些导入,但是当我添加时import org.apache.spark.streaming.kafka.kafkautils
其显示以下错误
对象kafka不是对象org.apache.spark.streaming.kafka.kafkautils的成员
与 eclipse
标量4.7
版本2.11.11,
spark-2.3.0-bin-hadoop2.7 jar文件,
卡夫卡2.11 jar ,
spark-streaming-kafka-0-10_2.11-2.3.0 jar
最佳答案
如果您使用的是park-streaming-kafka-0-10_2.11-2.3.0 jar
,则KafkaUtils可在此包的org.apache.spark.streaming.kafka010
中使用。
所以导入
import org.apache.spark.streaming.kafka010.KafkaUtils
并不是
import org.apache.spark.streaming.kafka.kafkautils
希望这个帮助!
关于scala - 在将Spark Streaming与Kafka集成时,Scala编程出现错误,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49559643/