我想使用Scala 2.11和flink 1.17（流）来使用Kafka消息。我尝试使用flink 1.17版本的库和依赖项。
但是，Scala 2.11不支持flink-scala-steaming（1.17）。当我尝试使用flink-scala-steaming（1.14）时发生了一个跨版本问题，它与Scala 2.11兼容。我还尝试使用Kafka源代码，但它要求它通过flink-api来提供。
我想使用Scala 2.11和flink 1.17（流）来使用Kafka消息。我尝试使用flink 1.17版本的库和依赖项。
但是，Scala 2.11不支持flink-scala-steaming（1.17）。当我尝试使用flink-scala-steaming（1.14）时发生了一个跨版本问题，它与Scala 2.11兼容。我还尝试使用Kafka源代码，但它要求它通过flink-api来提供。
1条答案
按热度按时间eqzww0vc1#
Flink从Flink 1.15开始就放弃了对Scala 2.11的支持，请参阅https://nightlies.apache.org/flink/flink-docs-stable/release-notes/flink-1.15/#drop-support-for-scala-211上的发行说明
因此，您不能将Flink 1.17与Scala 2.11结合使用。您需要升级到Scala 2.12或降级到Flink 1.14。