Flink 1.20.0读取Kafka Avro数据报错NoSuchMethodError求助

这个NoSuchMethodError本质是依赖版本冲突或不兼容：

• Flink 1.20.0中AvroDeserializationSchema.forGeneric(Schema)方法的存在性/签名，和你项目中引入的其他Avro/Flink相关依赖版本不匹配，导致运行时加载了错误版本的类，找不到目标方法。
• 最常见场景是：项目引入了Confluent Schema Registry适配依赖（比如flink-avro-confluent-registry），但该依赖的Flink/Avro版本和Flink 1.20.0不兼容。
• 也可能是pom.xml中依赖的scope配置错误（比如provided和compile混用），导致打包时引入了冲突的依赖包。

1. 统一Flink及相关依赖版本 #

确保所有Flink相关依赖（avro、kafka、schema registry适配包）都和Flink 1.20.0版本对齐：

• 若使用Confluent Schema Registry适配，需引入对应Flink版本的flink-avro-confluent-registry（版本号统一为1.20.0）。
• 检查pom.xml中所有org.apache.flink开头的依赖，版本全部设为1.20.0，禁止混合不同版本。

2. 排查并解决依赖冲突 #

用Maven命令生成依赖树，定位冲突的Avro/Flink依赖：

mvn dependency:tree -Dverbose -Dincludes=org.apache.avro,org.apache.flink

找到重复或版本不一致的依赖，在pom.xml中通过<exclusions>排除不兼容的版本。示例：

<dependency>
    <groupId>第三方依赖groupId</groupId>
    <artifactId>第三方依赖artifactId</artifactId>
    <version>第三方版本</version>
    <exclusions>
        <exclusion>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-formats-avro</artifactId>
        </exclusion>
    </exclusions>
</dependency>

3. 修正依赖Scope配置 #

• Flink核心依赖（如flink-java、flink-streaming-java）设置为provided（集群已自带），避免打包时重复引入。
• flink-formats-avro、flink-avro-confluent-registry这类格式适配依赖设为compile，确保打包时包含到作业JAR中。

4. 验证代码方法调用 #

确认代码中调用AvroDeserializationSchema.forGeneric的方式符合Flink 1.20.0的签名：

public static AvroDeserializationSchema<GenericRecord> forGeneric(Schema schema)

若参数类型错误也可能触发类似报错，但此类情况远少于依赖冲突。

• 查看JobManager日志，是否有ClassNotFoundException或LinkageError的前置报错，这类信息能直接指向冲突类。
• 解压作业JAR包，检查BOOT-INF/lib（Spring Boot打包）或根目录下的依赖，确认是否存在多版本的flink-formats-avro或avro相关JAR。

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