网站介绍：文章浏览阅读1k次。概述：spark-streaming-kafka-0-8_2.11 有两种方式连接Kafka，一种是Receiver，另一种是Direct。Receiver实现：def main(args: Array[String]): Unit = { //创建配置对象文件 val conf: SparkConf = new SparkConf().setAppName("SparkStreaming_Demo04").setMaster("local[*]") //创建SparkStr_使用sparkstreaming与kafka完成简单案例
- 链接地址：https://blog.csdn.net/weixin_44911081/article/details/122327513
- 链接标题：SparkStreaming整合Kafka实现wordcount案例（spark-streaming-kafka-0-8_2.11版）_使用sparkstreaming与kafka完成简单案例-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：311
- 网站标签：使用sparkstreaming与kafka完成简单案例
