我们需要使用 commitAsync
Kafka消费者api。Kafka0.9和0.10版本都有。
可以使用spark streaming 1.6版本和kafka 0.10吗?
根据我读过的博客和网站,kafka0.10只被sparkstreaming(spark2.1.x)版本使用/支持
Kafka本人在下面的链接中指出:https://blog.cloudera.com/blog/2017/06/offset-management-for-apache-kafka-with-apache-spark-streaming/
暂无答案!
目前还没有任何答案,快来回答吧!