特牛生活网

SparkStreaming整合Kafka实现wordcount案例(spark-streaming-kafka-0-10_2.11版)_spark使用kafka数据源实现wordcount-CSDN博客

网友收藏
文章浏览阅读976次。依赖导入:<dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming-kafka-0-10_2.11</artifactId> <version>2.4.5</version></dependency>代码实现:def main(args: Array[String]): U_spark使用kafka数据源实现wordcount