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
>

Reply via email to