Caused by: java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtils
1条回答
离线之间 2016-08-01 12:09关注org.apache.spark.streaming.kafka.KafkaUtils
你没有引入这个包啊，这个包名应该是
org.apache.spark
spark-streaming-kafka_2.10
1.6.1
版本自己选择，可以去maven 下载
http://mvnrepository.com/artifact/org.apache.spark/spark-streaming-kafka_2.10解决 无用评论 打赏举报
分享
- 2023-01-17 10:39回答 3 已采纳 这个是github上个人维护的spark-aql勾子程序,你的问题应该是设置高版本的spark和scala,造成了一些版本冲突,而且高版本中许多类都更新过了,当然找不到.(1)<import o
- 2022-11-08 20:23回答 1 已采纳 看下是不是还有报错classNotFoundException.应该是你导入包的时候补全 少了AvroSourceProtocol相关包或者是版本依赖错了.首先看下这个类是那个jar里面的，然后再分
- 2023-01-23 19:40回答 2 已采纳 看起来你好像少这个jar ： kafka-clients，查找一下项目里引用了没有 另外就是需要你check一下你代码里是否使用了 StringDeserializer 代替了 StringSer
- 2020-12-15 10:09oliver_lorne的博客 org.apache.spark.sql.streaming.StreamingQueryException: null Current Committed Offsets: {} Current Available Offsets: {} Caused by: java.lang.NumberFormatException: null
- 2022-12-23 16:57回答 2 已采纳 集群还在启动吧，还是在安全模式，无法创建文件夹，稍等一会儿集群完全启动成功后就可以了。
- 2017-08-04 10:06回答 1 已采纳 http://blog.csdn.net/svmachine/article/details/52200761
- 2021-10-25 15:00回答 2 已采纳 你好，我是有问必答小助手，非常抱歉，本次您提出的有问必答问题，技术专家团超时未为您做出解答本次提问扣除的有问必答次数，将会以问答VIP体验卡（1次有问必答机会、商城购买实体图书享受95折优惠）的形式为
- 2018-05-28 09:18架构文摘的博客 随着公司业务发展，对大数据的获取和实时处理的要求就会越来越高，日志处理、用户行为分析、场景业务分析等等，传统的写日志方式根本满足不了业务的实时处理需求，所以本人准备开始着...
- 2015-06-15 09:01回答 1 已采纳 问题已 解决。。。 allData 加上cache之后异常可以解决了，这是为什么呢？ 其中又出现了一个错误： ![图片说明](https://img-ask.csdn.net/upload/20
- 2021-08-06 17:20回答 1 已采纳 已解决，poi版本冲突问题
- 2022-08-22 12:13回答 2 已采纳 EGLSink改为以下：sink = Gst.ElementFactory.make("fakesink", "fakesink")
- jyyy1990的博客 报错org/apache/kafka/clients/consumer/Consumer 网上试了几个办法都没解决，最后把kafka-clients-0.10.0.1.jar和spark-streaming-kafka-0-10_2.11-2.4.5.jar放到master机器spark的jars目录里就不报这个错了，仅供...
- 2022-03-03 10:52回答 1 已采纳 建议百度。猜测是没有连接上。不好意思，这个没用过
- 2020-09-14 14:57CodeShelby的博客 在将SparkSreaming中的DStreaming打印输出时常发生这种错误： Exception in thread “main” java.lang.IllegalArgumentException: requirement failed: No output operations registered, so nothing to execute ...
- 2022-07-13 14:07数据带你飞的博客 目前，Spark生态系统已经发展成为一个包含多个子项目的集合，其中包含SparkCore、SparkSQL、Spark Streaming、GraphX、MLib、SparkR等子项目，Spark是基于内存计算的大数据并行计算框架。除了扩展了广泛使用的 ...
- 没有解决我的问题, 去提问
悬赏问题
- ¥15 stata安慰剂检验作图但是真实值不出现在图上
- ¥15 c程序不知道为什么得不到结果
- ¥40 复杂的限制性的商函数处理
- ¥15 程序不包含适用于入口点的静态Main方法
- ¥15 素材场景中光线烘焙后灯光失效
- ¥15 请教一下各位，为什么我这个没有实现模拟点击
- ¥15 执行 virtuoso 命令后，界面没有，cadence 启动不起来
- ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
- ¥20 有关区间dp的问题求解
- ¥15 多电路系统共用电源的串扰问题