Hi,
It is recommended to package your application with all the
dependencies into a single file [1].
And according to the kafka-connector documentation [2]:
if you are using Kafka source, flink-connector-base is also required
as dependency:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-base</artifactId>
<version>VERSION</version>
</dependency>
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/project-configuration/#flink-core-and-application-dependencies
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#dependency
Regards,
Roman
On Fri, Jul 23, 2021 at 5:42 PM igyu <i...@21cn.com> wrote:
>
> in my app pom.xml
>
> <dependency>
> <groupId>org.apache.flink</groupId>
> <artifactId>flink-connector-kafka_2.11</artifactId>
> <version>1.13.1</version>
> <scope>provided</scope>
> </dependency>
>
>
> and I have copy flink-connector-kafka_2.11-1.13.1.jar to FLINK_HOME/lib/
>
> but I also get a error
>
> ClassNotFoundException: org.apache.kafka.clients.consumer.ConsumerRecord
>
> so
> How can fix it?
> ________________________________
> igyu
