Apache Flink 1.4 with 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
)

Answer 2

试试

org.apache.flink" % "flink-connector-kafka-0.11_2.11" % "1.4.0

flink-connector-kafka-0.11_2.11是 Flink 最新的 Kafka 连接器。

资料来源： https://search.maven.org/#search%7Cga%7C1%7Cflink%20kafka%20connector ， https://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22org.apache.flink%22%20AND%20a%3A%22flink-connector-kafka-0.11_2.11%22

Kafka 1.0 代理向后兼容 0.11 和 0.10 API。