Hi Ran Tao, > task-side just continues to consume the removed partitions to the end.
I am curious about how task-side consumes removed partitions. Are you saying that the task-side can still run without exceptions even if the partition is removed from metadata? If so, the "removed partitions" only affects the unassigned partitions. If the partition has already been successfully unassigned, even if it no longer exists, it will not affect the task-side.Therefore, I suggest removing partitions from the pendingPartitionSplitAssignment so that unassigned but removed partitions will not be assigned to the task side. This assignment is redundant. By the way, I wonder under what situations Kafka removes a partition? Best Hongshun
