org.apache.flink.connector.kafka.source.KafkaSource java.lang.ClassNotFoundException: Flink

Question

我使用Kafka作为Flink job的数据源。当我将作业部署到flink集群作业管理器时，我收到一个错误ClassNotFoundException：Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource

下面是我的pom.xml依赖项

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kafka_2.12</artifactId>
            <version>1.13.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-avro</artifactId>
            <version>1.13.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-clients_2.12</artifactId>
            <version>1.13.0</version>
        </dependency>
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
        </dependency>
    </dependencies>

Answer 1

Flink本身不包含这些扩展JAR文件(您可以在flink/lib中找到jar文件)，如果您不将这些JAR输入到项目的jar文件(Uber jar)中，或者在提交任务时指定它们(请参见Flink文档)，flink运行时将找不到这些jar。

Answer 2

默认情况下，Flink连接器不在flink类路径下，您需要将kafka连接器maven依赖项添加到项目中