You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Avinash Tripathy <av...@stellapps.com> on 2020/02/18 09:46:22 UTC

Not able to consume kafka massages in flink-1.10.0 version

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

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

Posted by Stephan Ewen <se...@apache.org>.

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.tripathy@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
>