Description
We need to change the implementation based on https://cwiki.apache.org/confluence/display/KAFKA/kafka+Detailed+Replication+Design+V3
We need to change the implementation based on https://cwiki.apache.org/confluence/display/KAFKA/kafka+Detailed+Replication+Design+V3