Spark Streaming 不包含 KafkaUtils答案

【问题标题】：Spark Streaming doesn't contain KafkaUtilsSpark Streaming 不包含 KafkaUtils
【发布时间】：2017-02-21 06:10:51
【问题描述】：

我创建了一个项目，我想在其中使用 kafka 流。出于这个原因，我需要使用火花流中的 KafkaUtils。但是当我尝试使用 KafkaUtils 时，它们无法解决。

我添加了 spark-streaming_2.11-2.0.1.jar 并尝试导入 org.apache.spark.streaming.kafka.*;。但是也解决不了。

谁能告诉我我错过了什么？

亲切的问候

【问题讨论】：

【解决方案1】：

使用KafkaUtils前需要添加spark-streaming-kafka_2.11-2.0.1.jar

【讨论】：

【解决方案2】：

您需要在 Scala 中使用 import org.apache.spark.streaming.kafka._ 而不是 import org.apache.spark.streaming.kafka.*。

【讨论】：

【解决方案3】：

问题是我在使用

spark-streaming_2.11-2.0.1.jar

但我需要

spark-streaming-kafka_2.10-1.6.2.jar

没关系。

【讨论】：