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

Posted to user@flink.apache.org by Alexey Trenikhun <ye...@msn.com> on 2021/05/18 00:21:29 UTC

KafkaSource

Hello,

Is new KafkaSource/KafkaSourceBuilder ready to be used ? If so, is KafkaSource state compatible with legacy FlinkKafkaConsumer, for example if I replace FlinkKafkaConsumer by KafkaSource, will offsets continue from what we had in  FlinkKafkaConsumer ?

Thanks,
Alexey

Re: KafkaSource

Posted by Matthias Pohl <ma...@ververica.com>.

Hi Alexey,
the two implementations are not compatible. You can find information on how
to work around this in the Kafka Connector docs [1].

Best,
Matthias

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#upgrading-to-the-latest-connector-version

On Tue, May 18, 2021 at 2:21 AM Alexey Trenikhun <ye...@msn.com> wrote:

> Hello,
>
> Is new KafkaSource/KafkaSourceBuilder ready to be used ? If so, is KafkaSource
> state compatible with legacy FlinkKafkaConsumer, for example if I replace FlinkKafkaConsumer
> by KafkaSource, will offsets continue from what we had in
> FlinkKafkaConsumer ?
>
> Thanks,
> Alexey
>