我创建了一个要使用kafka流的项目。
因此,我需要使用Spark Streaming中的KafkaUtils。
但是当我尝试使用KafkaUtils时,它们无法解决。
我添加了spark-streaming_2.11-2.0.1.jar并尝试导入org.apache.spark.streaming.kafka。*;。但这也无法解决。
有人可以告诉我我所缺少的吗?
亲切的问候
最佳答案
您需要在使用KafkaUtils之前添加spark-streaming-kafka_2.11-2.0.1.jar
关于java - Spark Streaming不包含KafkaUtils,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/39998636/