Incremental Cooperative Rebalancing Protocol
-
[Kafka] - 12. Cooperative Sticky Assignor개발/Kafka 2022. 8. 9. 17:11
1. Consumer rebalancing Process by time 1. Consumer들이 Join Group Reqeust를 Group Coordinator에 보낸다.(Rebalance process start) 2. Join Group Response 및 Join Group 목록을 Group Leader(Consumer C)에게 전달한다. 3. 모든 Consumer들은 Broker에게 Sync Group Request ( Group Leader는 각 Consumer의 Partition 할당(assignor)을 계산하여 Group Coordinator에게 전달) 4. Broker들은 Sync Group Response로 각 Consumer 별 Partition 할당을 보낸다. 2. Eager Re..