我想使用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。