apache-kafka - 无法访问kafka.serializer.StringDecoder

Question

我已经添加了 kafka 和 Spark Streaming 的 sbt 包，如下所示:

"org.apache.spark" % "spark-streaming_2.10" % "1.6.1",
"org.apache.spark" % "spark-streaming-kafka_2.10" % "1.6.1"

但是当我想使用 kafkadirect 流时..我无法访问它..

val topics="CCN_TOPIC,GGSN_TOPIC"
val topicsSet = topics.split(",").toSet
val kafkaParams = Map[String, String]("metadata.broker.list" -> kafkaBrokers)

val messages= org.apache.spark.streaming.kafka.KafkaUtils[String, String, kafka.serializer.StringDecoder, StringDecoder](
  ssc, kafkaParams, topicsSet)

编译器无法识别 kafka.serializer.StringDecoder..

 object serializer is not a member of package org.apache.spark.streaming.kafka

编辑:我也尝试过

 import  _root_.kafka.serializer

..但是里面没有 StringDecoder..

Answer 1

请尝试此操作:添加文件

kafka_2.11-0.10.0.0.jar

到您的项目依赖项。它应该可以修复您的错误。