sparkstreaming直接从kafka消费数据

来源：化拓教育网

1、sparkstreaming直接从kafka消费数据

采用createDirectStream，示例：

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

转载于:https://www.cnblogs.com/VillageKnight-Ding/p/8145054.html

因篇幅问题不能全部显示，请点此查看更多更全内容

查看全文

违法及侵权请联系：TEL:199 18 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务