Spark Streaming 結合 Kafka 兩種不同的數據接收方式比較

DirectKafkaInputDStream 只在 driver 端接收數據,所以繼承了 InputDStream,是沒有 receivers 的 在結合 Spark Streaming 及 Kafka 的實時應用中,我們通常使用以下兩個 API 來獲取最初的 DStream(這裏不關心這兩個 API 的重載): KafkaUtils#createDirectStream 及 KafkaUtil
相關文章
相關標籤/搜索