Kafka partition 배정도
Producer가 topic partition에 기록하고 consumer group은 partition별 offset을 전진시킵니다.
Users service
emit user_createdkey: userId| topic: user_created | offset | owner |
|---|---|---|
| partition 0 | 41 | worker A |
| partition 1 | 38 | worker B |
| partition 2 | 44 | worker B |
Notifications
group: notificationscommit 후 재시작| 순서 | 같은 key는 같은 partition으로 보내야 유지 |
|---|---|
| 확장 | consumer 수가 partition 수를 넘으면 쉬는 worker 발생 |