I just had the idea of a "ReplayableSourceStateBackend". I opened up a JIRA issue where I described the idea about it [1].
I would love to hear your feedback: Do you think it is possible to implement (I am not sure if a pipeline can be fully reconstructed from the source elements when it e.g. comes to closing session windows or such)? Would it be useful for your usecases as well?
Locked
