SparkStreaming+kafka的Direct模式的整合

SparkStreaming+Kafka receiver模式 receiver模式原理图   receiver模式理解: 在SparkStreaming程序运行起来后,Executor中会有receiver tasks接收kafka推送过来的数据。数据会被持久化,默认级别为MEMORY_AND_DISK_SER_2,这个级别也可以修改。receiver task对接收过来的数据进行存储和备份,这
相关文章
相关标签/搜索