无法访问kafka.serializer.StringDecoder [英] Can't access kafka.serializer.StringDecoder

问题描述

我添加了来自kafka和spark stream的sbt软件包，如下所示:

I have added the sbt packages fro kafka and spark streaming as follow:

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

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

however when I wanna use the kafkadirect streams..I cant access it..

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.

The compiler doesn't recognize kafka.serializer.StringDecoder..

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

我也尝试过

 import  _root_.kafka.serializer

..但是其中没有StringDecoder.

..but there is no StringDecoder in that..

推荐答案

请尝试以下操作:添加文件

Please try this: add the file

kafka_2.11-0.10.0.0.jar

kafka_2.11-0.10.0.0.jar

您的项目依赖项.它应该可以解决您的错误.

to your project dependency. It should fix your error.

这篇关于无法访问kafka.serializer.StringDecoder的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！