Partition 개수가 5개로 고정되어있고
Consumer 개수가 3, 4, 5, 6 개라고 하자.
Consumer 가 3개 일 때
Partition 1 | Consumer 1 |
Partition 2 | |
Partition 3 | Consumer 2 |
Partition 4 | |
Partition 5 | Consumer 3 |
Consumer 가 4개 일 때
Partition 1 | Consumer 1 |
Partition 2 | |
Partition 3 | Consumer 2 |
Partition 4 | Consumer 3 |
Partition 5 | Consumer 4 |
Consumer 가 5개 일 때
Partition 1 | Consumer 1 |
Partition 2 | Consumer 2 |
Partition 3 | Consumer 3 |
Partition 4 | Consumer 4 |
Partition 5 | Consumer 5 |
이렇게 Consumer 가 Partition 개수를 더 갖거나 하여 Consume 하게 된다.
그럼 Consumer 가 6개일 때는?
Partition 1 | Consumer 1 |
Partition 2 | Consumer 2 |
Partition 3 | Consumer 3 |
Partition 4 | Consumer 4 |
Partition 5 | Consumer 5 |
Consumer 6 |
6번째 Consumer 는 일을 안 하고 놀게 됨.
'Kafka' 카테고리의 다른 글
[Kafka] connect 가 안 될 때 설명 링크 (0) | 2021.03.16 |
---|---|
[Kafka] Rebalance 간략한 설명 (0) | 2020.10.29 |
[Kafka] Consumer 의 Offset 초기화하는 방법 (0) | 2020.10.23 |
[Kafka] Topic 내의 message 지우는 방법 (0) | 2020.10.21 |
[Kafka] path 에 있는 파일들 Kafka 로 Producing 하는 스크립트 (0) | 2020.10.21 |