FlinkKafkaProducer是否实现SinkFunction<T>？addSink报类型不匹配如何解决？

org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer确实是SinkFunction接口的实现类，它继承的TwoPhaseCommitSinkFunction本身就实现了SinkFunction接口，正常场景下可以直接传入addSink方法使用，你遇到的报错完全是依赖配置问题导致的：

• Scala编译版本不匹配。你配置的flink-connector-kafka_2.11是基于Scala 2.11编译的组件，而flink-streaming-java_2.12是基于Scala 2.12编译的核心组件，不同Scala版本的Flink组件二进制互不兼容，导致JVM无法识别FlinkKafkaProducer是SinkFunction的子类。
• Flink组件版本号不统一。Kafka连接器使用的是1.13.0版本，而流处理核心包使用的是1.13.2版本，跨小版本的组件也可能存在类结构、接口实现的差异，引发类型匹配错误。

1. 统一所有Flink依赖的Scala版本，推荐统一使用2.12版本，将kafka连接器的artifactId修改为flink-connector-kafka_2.12
2. 统一所有Flink相关依赖的版本号，建议全部对齐为1.13.2版本，避免跨版本兼容问题

修改后的依赖配置参考：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka_2.12</artifactId>
    <version>1.13.2</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-base</artifactId>
    <version>1.13.2</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.12</artifactId>
    <version>1.13.2</version>
    <scope>provided</scope>
</dependency>

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