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

2021-07-26 Thread Roman Khachatryan
, 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 a

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

2021-07-23 Thread igyu
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