我创建了一个要使用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/

10-09 04:40