squah-confluent opened a new pull request, #22487: URL: https://github.com/apache/kafka/pull/22487
To accommodate asynchronous assignors, such as assignors offloaded to the background thread pool and client-side assignors, we require a builder to turn a new target assignment into records to be persisted. Previously, the logic lived within the TargetAssignmentBuilder classes. We copy the logic out into its own builder class, keeping the existing logic within the TargetAssignmentBuilders for now. Future commits will remove the record-building logic from the TargetAssignmentBuilder classes and update callers to use the new TargetAssignmentRecordsBuilders. Additionally, we have to handle concurrent member operations such as leaves and static member replacements when building the target assignment records for asynchronous assignors. These member operations update the target assignment directly. Once the new target assignment is ready, we have to apply any member operations we missed to it. That is, we act as if the member removals and static member replacements are reordered after the assignment calculation. -- 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]
