로딩
요청 처리 중입니다...

[KAFKA] 리플리케이션, ISR, 로그 세그먼트

 [KAFKA] 리플리케이션, ISR, 로그 세그먼트

리플리케이션 팩터 리플리케이션 팩터를 설정하면 지정한 수 만큼의 리플케이션을 가질 수 있음 토픽의 복제본이 아니라 파티션의 복제본을 다른 브로커에서 만듬 파티션의 리더를 통해서만 모든 읽기와 쓰기가 가능함 복제본은 리더의 데이터를 복제함 ISR 리더와 파티션은 InSyncReplicas(ISR)라는 논리적인 그룹으로 묶여있음 해당 그룹안에 속한 팔로워들만이 새로운 리더의 자격을 가질 수 있음 팔로워들은 리더의 데이터를 따라감 단 장애가 발생해서 팔로워들이 리더의 데이터를 못 따라간 상태에서 팔로워가 리더가 되면 데이터 정합성 문제 발생함 그렇기에 리더는 팔로워들이 복제 동작을 잘 하고 있는지 감시함 리더는 팔로워가 특정 주기만큼 복제 요청을 하지 않으면 ISR 그룹에서 제외시킴 컨슈머는 커밋된 메시지만 읽어갈 수 있음 -> ISR내 모든 팔로워까지 복제가 완료된 데이터만 읽을 수 있음 만약 커밋되지 않은 데이터를 읽을 수 있으면 동일한 토픽의 파티션에서 컨슘했어도 메시지가 일치하지 ...

# kafka # logCompaction