You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by "Marchant, Hayden " <ha...@citi.com> on 2018/02/01 13:46:51 UTC
Latest version of Kafka
What is the newest version of Kafka that is compatible with Flink 1.4.0? I see the last version of Kafka supported is 0.11 , from documentation, but has any testing been done with Kafka 1.0?
Hayden Marchant
RE: Latest version of Kafka
Posted by "Marchant, Hayden " <ha...@citi.com>.
Thanks for the info!
-----Original Message-----
From: Piotr Nowojski [mailto:piotr@data-artisans.com]
Sent: Friday, February 02, 2018 4:37 PM
To: Marchant, Hayden [ICG-IT] <hm...@imceu.eu.ssmb.com>
Cc: user@flink.apache.org
Subject: Re: Latest version of Kafka
Hi,
Flink as for now provides only a connector for Kafka 0.11, which is using KafkaClient in 0.11.x version. However you should be able to use it for reading to/writing from Kafka 1.0 - Kafka claims (and as far as I know it’s true) that Kafka 1.0 is backward compatible with 0.11.
Piotrek
> On 1 Feb 2018, at 14:46, Marchant, Hayden <ha...@citi.com> wrote:
>
> What is the newest version of Kafka that is compatible with Flink 1.4.0? I see the last version of Kafka supported is 0.11 , from documentation, but has any testing been done with Kafka 1.0?
>
>
> Hayden Marchant
>
Re: Latest version of Kafka
Posted by Piotr Nowojski <pi...@data-artisans.com>.
Hi,
Flink as for now provides only a connector for Kafka 0.11, which is using KafkaClient in 0.11.x version. However you should be able to use it for reading to/writing from Kafka 1.0 - Kafka claims (and as far as I know it’s true) that Kafka 1.0 is backward compatible with 0.11.
Piotrek
> On 1 Feb 2018, at 14:46, Marchant, Hayden <ha...@citi.com> wrote:
>
> What is the newest version of Kafka that is compatible with Flink 1.4.0? I see the last version of Kafka supported is 0.11 , from documentation, but has any testing been done with Kafka 1.0?
>
>
> Hayden Marchant
>