| 111 | } |
| 112 | |
| 113 | type roundRobinPartitioner struct { |
| 114 | partition int32 |
| 115 | } |
| 116 | |
| 117 | // NewRoundRobinPartitioner returns a Partitioner which walks through the available partitions one at a time. |
| 118 | func NewRoundRobinPartitioner(topic string) Partitioner { |
nothing calls this directly
no outgoing calls
no test coverage detected