RoundrobinGroupBalancer divides partitions evenly among consumers Example: 5 partitions, 2 consumers C0: [0, 2, 4] C1: [1, 3] Example: 6 partitions, 3 consumers C0: [0, 3] C1: [1, 4] C2: [2, 5]
| 101 | // C2: [2, 5] |
| 102 | // |
| 103 | type RoundRobinGroupBalancer struct{} |
| 104 | |
| 105 | func (r RoundRobinGroupBalancer) ProtocolName() string { |
| 106 | return "roundrobin" |
nothing calls this directly
no outgoing calls
no test coverage detected