...
Code Block | ||||
---|---|---|---|---|
| ||||
Initial group and assignment: A(T1), B(T2), C(T3), D(T4) D(T4) bounces. First leaves the group. Rebalance is triggered. Remaining member rejoin with subscriptions: A(T,assigned:T1), B(T,assigned:T2), C(T,assigned:T3) Leader computes detects "lost" partition T4. Sends empty assignments, without revocations and a scheduled rebalance timeout of t1: A(assigned:,revoked:,t1), B(assigned:,revoked:,t1), C(assigned:,revoked:,t1) Before t1, member D joins again as D' Rebalance is triggered. All members join with subscriptions: A(T,assigned:T1), B(T,assigned:T2), C(T,assigned:T3), D'(T,assigned:) Leader sends updated assignment: A(assigned:,revoked:,-), B(assigned:,revoked:,-), C(assigned:,revoked:,-), D'(assigned:T4,revoked:,-) |
...