Hi Yuval, It seems you are trying to perform bootstrapping on a Flink job by doing the bounded read first. A good pattern to follow is to use HybridSource [1] and the docs have some examples with File and Kafka sources. The point of switching can be coordinated by the source so that you can dynamically infer where to start from stream B. Please take a look at the link and let me know if you have additional questions.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/hybridsource/ Best, Mason On Wed, Mar 8, 2023 at 11:12 AM Yuval Itzchakov <yuva...@gmail.com> wrote: > Hi, > > I have a use-case where I have two streams, call them A and B. I need to > consume stream A up to a certain point, and only then start processing on > stream B. > > What could be a way to go about this? >
