rreddy-22 opened a new pull request, #13998: URL: https://github.com/apache/kafka/pull/13998
We want to make the assignors rack aware and in order to obtain and provide the rack Information the following interface modifications were made:- 1) AbstractPartitionAssignor implements the PartitionAssignor Interface : This contains an assign function with a metadata image argument that will be called from the TargetAssignmentBuilder. 2) TopicAndClusterMetadata :- This is a new data structure that will hold the ClusterImage and the TopicsImage both of which will be obtained from the MetadataImage. The rackInfo will be passed to another assign function which will have a List of rackAwareTopicIdPartitions. This information will be used by the assignors to match partition replica racks with consumer racks -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
