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

Sun, 12 Jul 2020 23:43:08 -0700 

@Leonard Xu，
非常感谢您的回复，我试了试您说的方式，还是报同样的错误，另外，我在 [1]
中并没有看到关于flink-sql-connecter-kafka相关的信息重新的pom如下：

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html
=============================
          <dependency>
            <groupId>org.apache.flink</groupId>

<artifactId>flink-sql-connector-kafka_${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-connector-kafka-0.11_2.11</artifactId>-->
            <!--<version>${flink.version}</version>-->
            <!--&lt;!&ndash;<scope>compile</scope>&ndash;&gt;-->
        <!--</dependency>-->

        <!--<dependency>-->
            <!--<groupId>org.apache.flink</groupId>-->
            <!--<artifactId>flink-connector-kafka_2.11</artifactId>-->
            <!--<version>${flink.version}</version>-->
        <!--</dependency>-->
=============================

Leonard Xu <xbjt...@gmail.com> 于2020年7月13日周一 下午1:39写道：

> 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>
> > =============================================
>
>

回复