The removed partitions will not notice the task-side. As I say, the task-side just continues to consume the removed partitions to the end. It will not cause an exception because the task-side has the remove-partitions's state and offset (even though these remove-partitions are indicated removed in SourceEnumerator).
Best Regards, Ran Tao Hongshun Wang <loserwang1...@gmail.com> 于2023年5月10日周三 11:10写道： > Hi Ran Tao, > > Thank you for your response. It's very helpful. > > I still have some questions: > > Currently, if a partition is removed, the reader will not be notified about > it. Will this cause an exception with the split reader?If this happens, the > system will never be able to restart successfully, repeatedly. > > Perhaps the reason why this issue has not been considered is because Kafka > does not allow for scaling partitions? > > > Yours > > Hongshun >
