KafkaSource

[Alexey Trenikhun]

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

[Matthias]

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