RangeGroupBalancer groups consumers by partition Example: 5 partitions, 2 consumers C0: [0, 1, 2] C1: [3, 4] Example: 6 partitions, 3 consumers C0: [0, 1] C1: [2, 3] C2: [4, 5]
| 50 | // C2: [4, 5] |
| 51 | // |
| 52 | type RangeGroupBalancer struct{} |
| 53 | |
| 54 | func (r RangeGroupBalancer) ProtocolName() string { |
| 55 | return "range" |
nothing calls this directly
no outgoing calls
no test coverage detected