[GitHub] [kafka] rajinisivaram commented on a diff in pull request #13474: KAFKA-14867: Trigger rebalance when replica racks change if client.rack is configured (KIP-881)

["rajinisivaram (via GitHub)" <gi...@apache.org>]

rajinisivaram commented on code in PR #13474:
URL: https://github.com/apache/kafka/pull/13474#discussion_r1154282863


##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##########
@@ -1613,14 +1615,18 @@ private ConsumerCoordinatorMetrics(Metrics metrics, String metricGrpPrefix) {
 
     private static class MetadataSnapshot {
         private final int version;
-        private final Map<String, Integer> partitionsPerTopic;
+        private final Map<String, List<RackInfo>> partitionsPerTopic;

Review Comment:
   Since we already have another PartitionInfo, I renamed this one `PartitionRackInfo`.



-- 
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-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org