Flink：在 CLI 上运行 flink 程序时出错答案

【问题标题】：Flink: Error while running the flink program on CLIFlink：在 CLI 上运行 flink 程序时出错
【发布时间】：2020-02-28 13:00:44
【问题描述】：

我正在尝试运行一个使用 kafka 连接器（最新的通用连接器）的 flink 蒸汽程序。这些作业在 IntelliJ 上运行没有任何问题，但是当我使用 sbt 包将代码构建到 jar 中时，出现以下错误。 java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase

我也使用了使用传统 IntellIJ 选项构建的 jar，但仍然出现上述错误。

【问题讨论】：

标签： apache-flink flink-streaming

【解决方案1】：

最有可能的问题是您没有在 JAR 文件中包含依赖项。 Flink 二进制文件中不包含连接器依赖项。通常，解决此问题的首选方法是为您的构建工具使用适当的插件，例如用于 Maven 的 shade-plugin 或用于 sbt 的 assembly 来创建所谓的 fat-jar，即包含依赖项的 JAR。

【讨论】：