我正在尝试添加一些导入，但是当我添加import org.apache.spark.streaming.kafka.kafkautils时，它显示了以下错误
对象卡夫卡不是对象org.apache.spark.streaming.kafka.kafkautils使用scala ide 4.7版本2.11.11、spark 2.3.0-bin-hadoop2.7 j
浏览 0提问于2018-03-29得票数 3
回答已采纳
><dependency> <artifactId>spark-streaming-kafka_AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:35
浏览 6提问于2016-08-24得票数 3
at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$createDirectStream$2.apply(KafkaUtils.scala:413)
at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$createDirectStream
浏览 5提问于2015-06-19得票数 1
2回答
<init>(TopicMetadataRequest.scala:55)at org.apache.spark.streaming.kafka.KafkaCluster.getPartitions(KafkaClus
浏览 2提问于2016-05-04得票数 0
3回答
：在org.apache.spark.streaming.kafka.KafkaCluster.getPartitions(KafkaCluster.scala:119) at org.apache.spark.streaming.kafka.KafkaUtils$.getFromOffsets(KafkaUtils.scala:211) at org.a
浏览 4提问于2017-11-15得票数 0
1回答
:46)at org.apache.spark.internal.Logging:40)
at org.apache.spark.streaming.kafka010.
浏览 0提问于2018-05-29得票数 1
下面是我得到错误的行import kafka.serializer.StringDecoderimport org.apache<
浏览 1提问于2018-04-30得票数 1
回答已采纳
1回答
我正试图在Scala中建立一个kafka消费者，使用Intellij来读取卡夫卡主题的信息，我在窗口上都有星火和卡夫卡。我试过这个代码：import org.apache.spark.streaming._import
浏览 3提问于2020-04-08得票数 0
回答已采纳
.ConsumerStrategies;import org.apache.spark.streaming.kafka010:46)
at org.apache.spark.streaming.kafka</e
浏览 5提问于2018-07-16得票数 2
回答已采纳
(Logging.scala:99) at org.apache.spark.internal.Logging$class.log(Logging.scala:46)
at org.<
浏览 1提问于2018-03-09得票数 18
回答已采纳
我使用spark streaming 'org.apache.spark:spark-streaming_2.10:1.6.1‘和'org.apache.spark:spark-streaming-kafka$.checkErrors(KafkaCluster.scala:365)
at org.apache<
浏览 11提问于2016-09-01得票数 4
回答已采纳
$.org$apache$spark$streaming$kaf ka$KafkaUtils$$checkOffsets(KafkaUtils.scala:200)
at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$createRDD$1.apply(KafkaUtils.scala:25
浏览 4提问于2016-12-15得票数 0
import org.apache.spark._import org.apache.spark.streaming.dstream._import <em
浏览 3提问于2017-11-06得票数 0
;
* Created by jonas157)
at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaU
浏览 2提问于2016-10-10得票数 1
回答已采纳
150)
at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.scala:215)at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.s
浏览 3提问于2017-05-16得票数 1
import _root_.kafka.serializer.DefaultDecoderimport org.apache.spark.SparkConfimport org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache</e
浏览 0提问于2018-05-22得票数 2
回答已采纳
: org/apache/spark/streaming/kafka/KafkaUtils$ at org.firststream.spark_kakfa.spark_kafka_streaming$.main(spark_kafka_streaming.scala:30) at org<
浏览 42提问于2016-08-12得票数 0
回答已采纳
1回答
org.apache.spark.streaming.dstream._import org.apache.spark.SparkConfimport Utilities._
import org.apache.spark.stream
浏览 2提问于2017-11-01得票数 1
1回答
:4:35: object kafka is not a member of package org.apache.spark.streaming` not found: value KafkaUtils
[error] val lines =
浏览 16提问于2019-01-12得票数 2
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号