Hi all, I noticed that the KafkaSourceReader did not have a pointer to the KafkaSubscriber, so I was wondering if this could be a bug:
1. User has a flink job with topic set A and takes savepoint 2. User modifies flink job to read from topic set B; however, splits are still read from topic set A (since there’s no logic to filter/remove splits). To clarify, I haven’t tested this scenario out myself, but just through reading the code, there was no logic to filter/remove splits. Just to add and complete. Best, Mason
