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