+1 (binding) Best, Leonard
> On Dec 26, 2022, at 4:22 PM, Qingsheng Ren <[email protected]> wrote: > > +1 (binding) > > Best, > Qingsheng > Ververica (Alibaba) > > On Wed, Dec 21, 2022 at 3:13 PM Dong Lin <[email protected]> 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 >>
