squah-confluent opened a new pull request, #21727: URL: https://github.com/apache/kafka/pull/21727
When a member leaves a group, its target assignment is directly removed. When a static member is replaced, its target assignment is moved to the new member. These target assignment updates can happen while an offloaded assignment is being computed. When an offloaded assignment has finished, we must not emit records for members that have left the group and we must apply any static member replacements that occurred to the emitted records, to match the behavior when assignments are not offloaded. That is, we act as if the member removals and static member replacements are reordered after the assignment. We break up the assignment process into two parts: computing the target assignment map and generating the records. Only the former can run on the executor. To generate the records without removed members and with static member replacements applied we need to use the current state of the group. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
