spark、kafka統合の問題：オブジェクトkafkaはorg.apache.spark.streamingのメンバーではありません

Question

IntelliJ IDEでスパークアプリケーション（スカラ）を構築中にエラーが発生します。 さらなる処理のためにカフカストリームを使用する単純なアプリケーションです。すべてのjarファイルを追加しましたが、IDEは未解決のインポートまたはコードステートメントを表示しません。

しかし、私はアーティファクトを構築しようとすると、私は エラーあることを示す2つのエラーを取得：（13、35）オブジェクトカフカがパッケージ

org.apache.spark.streaming 
import org.apache.spark.streaming.kafka.KafkaUtils 

Error:(35, 60) not found: value KafkaUtils 
    val messages: ReceiverInputDStream[(String, String)] = KafkaUtils.createStream(streamingContext,zkQuorum,"myGroup",topics) 

のメンバーではないが、私は同様の質問を見たが、ほとんどしていますpplのうち、sparkに提出中にこの問題について不平を言う。しかし、私はそれを一歩踏み出し、最終的にスパークするために提出されるjarファイルを構築するだけです。上に私はIntelliJ IDEを使用しており、スパークとスケーラには少し新しいです。ここで失われた。以下は

オマール

Answer 1

IntelliJ Error

おかげで理由は、あなたのpom.xmlとだけでなく、あなたの火花libディレクトリにspark-streaming-kafka-K.version-Sc.version.jarを追加する必要があるということであるIntelliJのエラーのスナップショットです。