apache-kafka - Apache Flink 1.4 与 Apache Kafka 1.0.0

Question

我正在尝试将 Apache Flink Scala 项目与 Apache Kafka 1.0.0 集成。当我尝试在 build.sbt 文件中添加 flink-connector-kafka 包时，我收到一条错误消息，指出它无法解析它。

当我查看 Maven 存储库中可用的选项时，对于 0.10.2 以上的任何版本，Apache Kafka 2.11-1.0.0 都没有可用的 Maven 依赖项

val flinkVersion = "1.4.1"
val flinkDependencies = Seq(
    "org.apache.flink" %% "flink-scala" % flinkVersion % "provided",
    "org.apache.flink" %% "flink-streaming-scala" % flinkVersion % "provided")
    "org.apache.flink" %% "flink-connector-kafka" % flinkVersion)

有谁知道如何正确集成这些版本，以便我可以将 Apache Flink 1.4 连接到 Apache Kafka 2.11-1.0.0，因为我似乎没有尝试过任何工作(而且我不希望降级我正在连接的 Kafka 版本)到)。

Answer 1

这应该有效。尝试:

val flinkVersion = "1.4.2"

libraryDependencies ++= Seq(
  "org.apache.flink" %% "flink-streaming-scala" % flinkVersion,
  "org.apache.flink" %% "flink-connector-kafka-0.11" % flinkVersion
)