+1 (binding) Best, Qingsheng Ververica (Alibaba)
On Wed, Dec 21, 2022 at 3:13 PM Dong Lin <lindon...@gmail.com> wrote: > 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 >
