Not able to consume kafka massages in flink-1.10.0 version

[Avinash Tripathy]

Hi,

I am getting this error message.

Flink version: 1.10.0

Kafka version: kafka_2.12-2.1.0

Thanks,

Avinash

[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 <[hidden email]> wrote:

Hi,

I am getting this error message.

Flink version: 1.10.0

Kafka version: kafka_2.12-2.1.0

Thanks,

Avinash