网站介绍:文章浏览阅读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\")"
- 链接地址:https://blog.csdn.net/qq_45769990/article/details/116565990
- 链接标题:Structed Streaming集成kafka_"java structed sparksession readstream(\"kafka\")"-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:4642
- 网站标签:"java structed sparksession readstream(\"kafka\")"