[KAFKA-14891] Fix rack-aware range assignor to improve rack-awareness with co-partitioning

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.5.0
• Assignee: Rajini Sivaram
• Reporter: Rajini Sivaram
• Reviewer: David Jacot
• Created: 11/Apr/23 12:42
• Updated: 12/Apr/23 07:36
• Resolved: 12/Apr/23 07:36

Description

We currently check all states for rack-aware assignment with co-partitioning (https://github.com/apache/kafka/blob/396536bb5aa1ba78c71ea824d736640b615bda8a/clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java#L176). We should check each group of co-partitioned states separately so that we can use rack-aware assignment with co-partitioning for subsets of topics.

Issue Links

• links to: GitHub Pull Request #13539