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

Reply via email to