I am trying to understand the replication procedure and saw this document
https://cwiki.apache.org/confluence/display/KAFKA/kafka+Detailed+Replication+Design+V3
describing:

LeaderAndISR path: stores leader and ISR of a partition

/brokers/topics/[topic]/[partition_id]/leaderAndISR --> {leader_epoc:
epoc, leader: broker_id, ISR: {broker1, broker2}}

However, the correct path seems to have been
/brokers/topics/[topic]/partitions/[partition_id]/state

and returning
{controller_epoch:epoc, leader:broker_id, version:version_id,
leader_epoch:epoc, isr:[broker_id, ...]}

I suppose this document was not updated when the path changed?

regards, aki

Reply via email to