前面写了关于kafka和spark streaming的结合使用(https://www.cnblogs.com/qfxydtk/p/11662591.html),其具体使用用法其实来自于原文:http://spark.apache.org/docs/2.2.0/streaming-kafka-integration.html

在前文的参考文献中也列举出了此地址,但是在使用时,spark-streaming-kafka-0-8是稳定版,spark-streaming-kafka-0-10是实验版,但根据maven仓库显示此版本的使用情况,发现已经有很多在用,所以将此用于线上环境完全可以。但是需要配合kafka版本的稳定性,原文中叙述:0-8版本适配老的0.9和0.10甚至更早的kafka版本,而0-10版本则不兼容。

本来想自己翻译一番,发现最好的翻译在这里,也感谢原文作者做出的贡献。

https://mp.weixin.qq.com/s?__biz=MzA3MDY0NTMxOQ==&mid=2247484604&idx=1&sn=c7fb09731502041562894ad9ef06a8ca&chksm=9f38e794a84f6e82dddf1b6c0b081f7f3e0512b85557e7165f87c443ca804f7af6e11846cffa&scene=21#wechat_redirect

05-04 01:11