ClassNotFoundException: org.apache.kafka.clients.consumer.ConsumerRecord

[igyu]

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