(version string)
| 193 | } |
| 194 | |
| 195 | func parseVersion(version string) sarama.KafkaVersion { |
| 196 | result, err := sarama.ParseKafkaVersion(version) |
| 197 | if err != nil { |
| 198 | printUsageErrorAndExit(fmt.Sprintf("unknown -version: %s", version)) |
| 199 | } |
| 200 | return result |
| 201 | } |
| 202 | |
| 203 | func generateMessages(topic string, partition, messageLoad, messageSize int) []*sarama.ProducerMessage { |
| 204 | messages := make([]*sarama.ProducerMessage, messageLoad) |
no test coverage detected