https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Controller+Internals