Hi all, We created FLIP-208: Update KafkaSource to detect EOF based on de-serialized records. Please find the KIP wiki in the link https://cwiki.apache.org/confluence/display/FLINK/FLIP-208%3A+Update+KafkaSource+to+detect+EOF+based+on+de-serialized+records .
This FLIP aims to address the use-case where users need to stop a Flink job gracefully based on the content of de-serialized records observed in the KafkaSource. This feature is needed by users who currently depend on KafkaDeserializationSchema::isEndOfStream() to migrate their Flink job from FlinkKafkaConsumer to KafkaSource. Could you help review this FLIP when you get time? Your comments are appreciated! Cheers, Dong
