Hi all, I have submitted KIP-881 to implement rack-aware partition assignment for consumers: https://cwiki.apache.org/confluence/display/KAFKA/KIP-881%3A+Rack-aware+Partition+Assignment+for+Kafka+Consumers. It adds rack id to the consumer group protocol to propagate rack information so that rack-aware assignors can be added to benefit from locality.
Feedback and suggestions are welcome! Thank you, Rajini
