Hey Qihua, If I understand correctly, you should be able to with the HybridSource, released in 1.14 [1]
Best, Austin [1]: https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/hybridsource/ On Fri, Nov 5, 2021 at 3:53 PM Qihua Yang <yang...@gmail.com> wrote: > Hi, > > Our stream has two sources. one is a Kafka topic, one is a database. Is it > possible to consume from kafka topic only after DB scan is completed? We > configured it in batch mode. > > Thanks, > Qihua >
