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
