THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- with fan-in topology, downstream needs to match incomplete record with the upstream; but this can should be handled by having separate input channels already - (given we have stable channel ids) (need to check)
- output buffers need to be sent to the right channel; this is a problem if we rely on keys and don't t have stable channels ids
- when scaling-in upstream, buffers of incomplete records need to be matched
- when scaling-in downstream, there can be multiple incomplete records in input buffers (it can be a single input channel after recovery)
...