无法访问 kafka.serializer.StringDecoder [英] Can't access kafka.serializer.StringDecoder
本文介绍了无法访问 kafka.serializer.StringDecoder的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我已经添加了 kafka 和 spark 流的 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屋!
查看全文