Hi Bin, Flinks Kafka source has been rewritten using the new Source API. You can find it here: https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java
On Wed, Aug 4, 2021 at 8:51 PM Xinbin Huang <b...@apache.org> wrote: > Hi team, > > I'm trying to develop a custom source using the new Data Source API but I > have some hard time finding examples for it. Can you point me to some > existing Sources implemented with the new Data Source API? It would be > ideal if source is for a pull-based unbound source (i.e. Kafka). > > Thanks! > Bin > -- Best Regards, Yuval Itzchakov.
