我正在尝试将 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 版本)到)。
最佳答案
这应该有效。尝试:
val flinkVersion = "1.4.2"
libraryDependencies ++= Seq(
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion,
"org.apache.flink" %% "flink-connector-kafka-0.11" % flinkVersion
)
关于apache-kafka - Apache Flink 1.4 与 Apache Kafka 1.0.0,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49084618/