我爱普洱茶 发表于 2025-4-26 09:25:04

Spark-Streaming核心编程(2)

Kafka 0-10 Direct 模式

需求:
      通过 SparkStreaming 从 Kafka 读取数据,并将读取过来的数据做简朴盘算,最终打印到控制台。
导入依赖

https://i-blog.csdnimg.cn/direct/dc83131be9774f199c4174bfc002e6e7.jpg
 编写代码

https://i-blog.csdnimg.cn/direct/5d5b784b62a64642b89e6d4e5700c83c.jpg
 
https://i-blog.csdnimg.cn/direct/2b4c6834083f47eda74c7a1c43aac34f.jpg 
 开启Kafka集群和Kafka生产者

留意:开启Kafka集群前必要开启三台机器的zookeeper,启动下令zkServer.sh start
https://i-blog.csdnimg.cn/direct/cb68fd4e92154ce6b12bfbac1b7b9541.jpg
 在控制台输入数据,运行步伐,接受Kafka生产的数据
https://i-blog.csdnimg.cn/direct/296b55d7031641a292390d8810c7af90.jpg
 https://i-blog.csdnimg.cn/direct/c8e43c62bfe64ae1a560c766c6826228.jpg
 

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页: [1]
查看完整版本: Spark-Streaming核心编程(2)