spark streaming与kafka整合

Spark 2.2和2.3支持0.8和0.10两种Kafka API，而且0.8版本的API可以和Kafka Broker 0.9 及0.10兼容，但0.10版本的API不能与Kakka 0.8兼容。两个版本Kafka API的功能对比如下： 由此可知，相对于0.8版本，Kafka API 0.10版本的主要变化在于： 1）只支持Direct DStream 的连接模式，基于Receiver的⽅式

>>阅读原文<<