Hi all, How would one go about migrating a stateful streaming application that doesn't use Flink to one that does?
My question is specifically how to load state for the first time? I can set the source operator (Kafka in my case) to start from a desired point in time but I've no idea how I'd go about initialising the state of the Flink equivalent version of the app from a "pseudo-snapshot". I call "pseudo-snapshot" to the non-Flink representation of state at a given point in time. Thanks, Eduardo
