@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>--> <!--<!–<scope>compile</scope>–>--> <!--</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> > > ============================================= > >