하나의 Partition 에는 하나의 Consumer 가 할당되고
하나의 Consumer 는 하나 이상의 Partition 에서 데이터를 읽어올 수 있다.
이것은 Kafka 의 기본적인 규칙임.
만약 서로 매칭되어있던 Partition 과 Consumer 의 관계가 깨지면
다시 매칭시키기 위해 Rebalance 가 일어남.
예를 들어, Consumer 가 새로 추가되거나 기존의 Consumer 가 사라지게 되면 Rebalance 가 일어남.
Rebalance 하는 동안에는 Kafka 로부터 메세지를 읽어올 수 없게 됨.
Rebalance 는 토픽의 각 Partition 들이 하나의 Consumer 에 연결/매칭되고,
Rebalance 가 끝난 후에야 Consumer 들은 kafka 로부터 메세지를 읽어올 수 있게 됨.
참고
saramin.github.io/2019-09-17-kafka/
'Kafka' 카테고리의 다른 글
[Kafka] standalone 설치 방법 (0) | 2021.03.26 |
---|---|
[Kafka] connect 가 안 될 때 설명 링크 (0) | 2021.03.16 |
[Kafka] Partition 과 Consumer 개수 간 관계 (0) | 2020.10.29 |
[Kafka] Consumer 의 Offset 초기화하는 방법 (0) | 2020.10.23 |
[Kafka] Topic 내의 message 지우는 방법 (0) | 2020.10.21 |