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:
org.apache.flink
flink-connector-base
VERSION
[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 wrote:
>
> in my app pom.xml
>
>
> org.apache.flink
> flink-connector-kafka_2.11
> 1.13.1
> provided
>
>
>
> 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
