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的⽅式

>>阅读原文<<