- 链接地址：https://blog.csdn.net/qq_45769990/article/details/116565990
- 链接标题：Structed Streaming集成kafka_"java structed sparksession readstream(\"kafka\")"-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：7556
文章浏览阅读201次。读取kafka数据 // 构建SparkSession实例对象，相关配置进行设置 val spark: SparkSession = SparkSession.builder() .appName(this.getClass.getSimpleName.stripSuffix("$")) .master("local[2]") // 设置Shuffle时分区数目 .config("spark.sql.shuffle.partitions", "2"_"java structed sparksession readstream(\"kafka\")"
版权声明：本文发布于特牛生活网 内容均来源于互联网 如有侵权联系删除
