Re: flink sql报错 Could not find any factory for identifier 'kafka'

Sun, 12 Jul 2020 22:40:08 -0700 

Hi, 王松

这个报错是pom中缺少了 Kafka SQL connector的依赖，你引入的依赖都是Kafka datastream  connector 
的依赖，正确的依赖是：flink-sql-connector-kafka-${version}_${scala.binary.version} 
可以参考官网文档[1], 查看和下载SQL Client Jar. 另外， Kafka SQL connector 和 Kafka datastream  
connector 同时引用是会冲突的，请根据你的需要使用。


祝好，
Leonard Xu
[1]https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html
 
<https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html>
>        <dependency>
>            <groupId>org.apache.flink</groupId>
> 
> <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
>            <version>${flink.version}</version>
>        </dependency>
>        <dependency>
>            <groupId>org.apache.flink</groupId>
> 
> <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
>            <version>${flink.version}</version>
>        </dependency>
>        <dependency>
>            <groupId>org.apache.flink</groupId>
> 
> <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
>            <version>${flink.version}</version>
>        </dependency>
>        <dependency>
>            <groupId>org.apache.flink</groupId>
>            <artifactId>flink-core</artifactId>
>            <version>${flink.version}</version>
>        </dependency> 
> =============================================

回复