求助：Flink Kafka流程序本地正常，CLI提交JAR报ClassNotFoundException

这个问题我碰到过好多次了，核心原因就是依赖打包不全或者作用域配置不对——本地IntelliJ能跑是因为它会自动加载所有开发依赖，但打包后的JAR默认不会包含所有依赖，咱们一步步来解决：

1. 检查并调整sbt依赖作用域 #

首先看你的build.sbt里Kafka连接器的依赖配置，大概率是把作用域设成了provided（或者默认没指定，但Flink相关依赖有时默认是provided）。这种情况下，sbt打包时不会把这个依赖打进JAR里，而集群环境又没预装这个连接器，就会报ClassNotFoundException。

修改成compile作用域，确保打包时包含该依赖：

// 替换成你实际使用的Flink版本，比如1.17.0
val flinkVersion = "1.17.0"

libraryDependencies += "org.apache.flink" %% "flink-connector-kafka" % flinkVersion % "compile"

2. 构建包含所有依赖的胖JAR（Uber JAR） #

默认的sbt package只会打包你自己的代码，不会包含第三方依赖，所以需要用sbt-assembly插件构建胖包，把所有依赖都打进一个JAR里：

• 第一步：在project/plugins.sbt中添加assembly插件（版本可以用最新的，这里举个常用版本）：

addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "1.2.0")

• 第二步：在项目根目录运行命令构建胖包：

sbt assembly

• 构建完成后，胖包会生成在target/scala-<你的Scala版本>/目录下，文件名一般是[项目名]-assembly-[版本号].jar，用这个JAR提交到Flink CLI就不会缺类了。

3. 集群环境预安装连接器（可选） #

如果不想打胖包，你也可以把Kafka连接器的JAR放到Flink集群的lib目录下，然后重启Flink集群。这样集群会自动加载这个依赖，之后提交普通JAR时就不会报错了。不过这种方式需要你有集群的修改权限，适合固定的生产环境。

补充一句：IntelliJ本地能正常运行，是因为它在开发模式下会把所有依赖（包括provided作用域的）都加入类路径，所以不会出现缺类的问题，但打包时就不一样啦。

内容的提问来源于stack exchange，提问作者Bishamon Ten