Re: Not able to consume kafka massages in flink-1.10.0 version

2020-02-18 Thread Stephan Ewen
This looks like a Kafka version mismatch. Please check that you have the right Flink connector and not any other Kafka dependencies from in the classpath. On Tue, Feb 18, 2020 at 10:46 AM Avinash Tripathy < avinash.tripa...@stellapps.com> wrote: > Hi, > > I am getting this error message. > >

Not able to consume kafka massages in flink-1.10.0 version

2020-02-18 Thread Avinash Tripathy
Hi, I am getting this error message. [image: flink-kafka-consumer-error.png] Flink version: 1.10.0 Kafka version: kafka_2.12-2.1.0 Thanks, Avinash