Hi all, We would like to start the vote for FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records [1]. This FLIP was discussed in this thread [2].
This feature is needed by users who currently depend on KafkaDeserializationSchema::isEndOfStream() to migrate their Flink job from FlinkKafkaConsumer to KafkaSource. And we won't be able to remove FlinkKafkaConsumer and FlinkKafkaProducer before adding this feature. Thanks, Dong [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-208%3A+Add+RecordEvaluator+to+dynamically+stop+source+based+on+de-serialized+records [2] https://lists.apache.org/thread/z87m68ggzkx0s427tmrllswm4l1g7owc
