1、sparkstreaming直接從kafka消費(fèi)數(shù)據(jù)

采用createDirectStream，示例：

createDirectStream[K,?V,?KD <:?Decoder[K],?VD <:?Decoder[V]](ssc:?StreamingContext,?kafkaParams:?Map[String,?String],?topics:?Set[String])

?

轉(zhuǎn)載于:https://www.cnblogs.com/VillageKnight-Ding/p/8145054.html

與50位技術(shù)專家面對面20年技術(shù)見證，附贈技術(shù)全景圖

總結(jié)

以上是生活随笔為你收集整理的sparkstreaming直接从kafka消费数据的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。