KafkaUtils.createDirectStream报错Cannot resolve symbol createDirectStream
2024-10-08 08:07:57
一开以为是自己导包导错了,但是对比了一下之前的程序发现并没有错,
import org.apache.spark.streaming.kafka.{HasOffsetRanges, KafkaUtils, OffsetRange}
后来又怀疑是不是自己搞错版本了,检查了好几次,在另外一台电脑上也是同样的pom啊
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_2.11</artifactId>
<version>1.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming-kafka_2.11</artifactId>
<version>1.6.0</version>
</dependency>
后来又猜是不是哪里有隐式转换啊,因为我把KafkaUtils.createDirectStream放到一个函数中就不报错了,奇怪了
KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc,kafkaParams,topics)
搞了好久,最后是一个让我哭笑不得的原因导致的,topic的类型应该是Set,弄成Array了(话说Set确实更合理哈,自动去除重复的topic),说来也是气人,topic类型错了,IDEA就应该把错误标在topics上,标在createDirectStream误导人-_-||
最新文章
- Android项目实战(二十八):Zxing二维码实现及优化
- Web 开发最有用的50款 jQuery 插件集锦——《综合篇》
- openssl 证书操作命令
- 使用网易ubuntu镜像加速软件包安装
- 关于Warn:name or service not known的解决办法
- Ubuntu下安装JDK图文详解
- WGS84经纬度坐标与web墨卡托之间的转换【转】
- C语言初学 俩数相除问题
- Vlc for Android 全面阐述
- leetcode Reverse Integer python
- LigerUI+MVC的应用1
- redis学习(2)--- Redis概述
- CentOS7安装后配置MariaDB
- Request 和 Response 区别
- LINUX下的U盘挂载
- 使用JMeter的HTTP代理服务器录制app脚本
- .net core Include问题
- python第十二天 生成器,迭代器,内置函数
- windows下git显示文件被修改,实际没有改动的问题解决办法
- odoo-开发笔记 列表视图 增加记录弹出窗口效果