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 |