【发布时间】:2019-02-19 22:08:48
【问题描述】:
可供下载的最新版 Kafka 是 Kafka 2.1.0。但是为了在 Spark Streaming 或 Spark Structured Streaming 中使用 Kafka,我们分别使用以下连接器:
spark-streaming-kafka-0-10_2.11
spark-sql-kafka-0-10_2.11
我的问题是,连接器似乎适用于 Kafka 版本 0.10.0.0,因为连接器的名称包括 0-10。这里有什么我不明白的地方,还是我们真的在使用适用于更旧版本 Kafka 的连接器?
【问题讨论】:
-
0.10为Kafka版本,2.11为SCALA版本(与Kafka v 2.1.0无关)
-
我知道他们不相关;但 0-10 指的是 Kafka 代理版本 .10.0.0,它是 Kafka 的一个非常旧的版本。
标签: apache-spark apache-kafka apache-spark-sql spark-streaming