brokeProducer refuses to partition anything not on the “test” topic, and sends everything on that topic to partition 15.
| 240 | // brokeProducer refuses to partition anything not on the “test” topic, and sends everything on |
| 241 | // that topic to partition 15. |
| 242 | type brokePartitioner struct{} |
| 243 | |
| 244 | func (brokePartitioner) Partition(msg *sarama.ProducerMessage, n int32) (int32, error) { |
| 245 | if msg.Topic == "test" { |
nothing calls this directly
no outgoing calls
no test coverage detected