sparkstreaming直接从kafka消费数据
生活随笔
收集整理的這篇文章主要介紹了
sparkstreaming直接从kafka消费数据
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
1、sparkstreaming直接從kafka消費數據
采用createDirectStream,示例:
createDirectStream[K,?V,?KD <:?Decoder[K],?VD <:?Decoder[V]](ssc:?StreamingContext,?kafkaParams:?Map[String,?String],?topics:?Set[String])
?
轉載于:https://www.cnblogs.com/VillageKnight-Ding/p/8145054.html
與50位技術專家面對面20年技術見證,附贈技術全景圖總結
以上是生活随笔為你收集整理的sparkstreaming直接从kafka消费数据的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Java多线程系列--“基础篇”09之
- 下一篇: NPOI随笔——图片在单元格等比缩放且居