squah-confluent opened a new pull request, #22485: URL: https://github.com/apache/kafka/pull/22485
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 an OverlayMap class, to be used to provide the updated views of members and assignments. -- 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]
