| 92 | } |
| 93 | |
| 94 | type randomPartitioner struct { |
| 95 | generator *rand.Rand |
| 96 | } |
| 97 | |
| 98 | // NewRandomPartitioner returns a Partitioner which chooses a random partition each time. |
| 99 | func NewRandomPartitioner(topic string) Partitioner { |
nothing calls this directly
no outgoing calls
no test coverage detected