0

我们需要使用commitAsyncKafka消费者的API。它适用于 Kafka 0.9 和 0.10 版本。

可以将 Spark 流式传输 1.6 版本与 Kafka 0.10 一起使用吗?

根据我读过的博客和网站,Kafka 0.10 仅由 spark 流 (Spark 2.1.X) 版本使用/支持

Kafka 本身指向以下链接: https ://blog.cloudera.com/blog/2017/06/offset-management-for-apache-kafka-with-apache-spark-streaming/

4

0 回答 0