我正在尝试添加一些导入,但是当我添加时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/

10-12 18:55