Ở bài trước, ta dùng replication factor để replicate các partition và lưu trữ trên các kafka broker. Kafka sẽ có 1 và chỉ 1 replication partition là leader, chính vì thế việc read/write message sẽ đều thông qua partition này.
Tại một thời điểm, mỗi partition có duy nhất một replication leader.
Chỉ có thể read/write message từ replication leader.
Các replication còn lại được gọi là ISR, đồng bộ message từ replication leader.
Do vậy, mỗi partition có duy nhất một replication leader và một hoặc nhiều ISR - in-sync replica.
image
Trong trường hợp Broker 101 gặp sự cố, replication leader của partition 1 không còn hoạt động. Lúc này, một trong các ISR còn lại sẽ trở thành Leader và partition trở lại hoạt động bình thường.