squah-confluent opened a new pull request, #22486: URL: https://github.com/apache/kafka/pull/22486
To accommodate asynchronous assignments, such as those from client-side assignors and assignors offloaded to background threads, we want to split the TargetAssignmentBuilders into two: one builder for building the target assignment and another for building the target assignment records. Client-side assignors will only use the second builder. Both builders require an up-to-date view of group members at the time they are run. In the non-offloaded case, this is the same view. However, the view needs to include the unwritten member operations from the ongoing heartbeat request. Currently the operations are applied within the TargetAssignmentBuilders. To avoid duplicating the logic once the TargetAssignmentBuilders are split, we would like to lift it out and pass the TargetAssignmentBuilders the updated view of members and assignments. Add UpdatedMembersAndTargetAssignmentView, which provides updated views of members and target assignments after unwritten member joins, updates and leaves. Future commits will update the consumer, share and streams group assignment paths to use the new class. -- 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]
