(scheme string)
| 158 | ) |
| 159 | |
| 160 | func parseCompression(scheme string) sarama.CompressionCodec { |
| 161 | switch scheme { |
| 162 | case "none": |
| 163 | return sarama.CompressionNone |
| 164 | case "gzip": |
| 165 | return sarama.CompressionGZIP |
| 166 | case "snappy": |
| 167 | return sarama.CompressionSnappy |
| 168 | case "lz4": |
| 169 | return sarama.CompressionLZ4 |
| 170 | default: |
| 171 | printUsageErrorAndExit(fmt.Sprintf("Unknown -compression: %s", scheme)) |
| 172 | } |
| 173 | panic("should not happen") |
| 174 | } |
| 175 | |
| 176 | func parsePartitioner(scheme string, partition int) sarama.PartitionerConstructor { |
| 177 | if partition < 0 && scheme == "manual" { |
no test coverage detected