Commit ca9eed9

committed

implement rack aware

add ut add IT improve test

1 parent 3f75f45 commit ca9eed9Copy full SHA for ca9eed9

3 files changed

+1415

-17

lines changed

clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer
- ConsumerIntegrationTest.java
group-coordinator/src
- main/java/org/apache/kafka/coordinator/group/assignor
  - RangeAssignor.java
- test/java/org/apache/kafka/coordinator/group/assignor
  - RangeAssignorTest.java

+1415

-17

lines changed

Comments

(0)