Apache Flink消费AWS Kinesis触发FlinkKinesisConsumer类未找到异常

该异常的根因是运行时类路径中缺少Flink Kinesis连接器的对应类，按以下步骤排查修复即可：

• 第一步：配置正确的项目依赖
  首先在你的构建配置文件（Maven的pom.xml或Gradle的build.gradle）中引入和你使用的Flink版本完全匹配的Kinesis连接器依赖，Maven配置示例如下：

<!-- 替换${flink.version}为你实际使用的Flink核心版本，例如1.16.2、1.17.1 -->
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kinesis</artifactId>
    <version>${flink.version}</version>
    <!-- 本地调试、打全量Jar提交集群时scope设为compile；若集群已预置该连接器，可改为provided -->
    <scope>compile</scope>
</dependency>

• 第二步：按运行场景调整打包逻辑
  • 本地IDE运行：确保IDE项目依赖中该连接器的scope未被设置为Provided，否则运行时不会加载该依赖
  • 提交到自建Flink集群运行：使用maven-shade-plugin或Gradle Shadow插件将所有依赖打包为Fat Jar后提交，避免集群类路径缺失依赖
  • 提交到AWS Kinesis Data Analytics托管运行：确认你使用的Flink版本和托管环境支持的版本完全匹配，托管环境预置的连接器版本需和你编译用的版本一致
• 额外注意点：你当前代码中引入的configs.AWSConfigConstants为自定义配置类，正确的常量类应该是连接器自带的org.apache.flink.streaming.connectors.kinesis.config.AWSConfigConstants，类找不到问题修复后如果出现配置不生效的情况，可以排查此处常量定义是否正确。

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