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. > > [image: flink-kafka-consumer-error.png] > > Flink version: 1.10.0 > Kafka version: kafka_2.12-2.1.0 > > Thanks, > Avinash >
