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]