Merge pull request #63 from shyam334/fix/KafkaKeying

Fix cli param default value - kafka.key
cloudflare · Mar 5, 2020 · c970b07 · c970b07
2 parents ef5ec28 + 8067f51
commit c970b07
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/transport/kafka.go b/transport/kafka.go
@@ -60,7 +60,7 @@ func RegisterFlags() {
 	KafkaLogErrors = flag.Bool("kafka.log.err", false, "Log Kafka errors")
 
 	KafkaHashing = flag.Bool("kafka.hashing", false, "Enable partitioning by hash instead of random")
-	KafkaKeying = flag.String("kafka.key", "SamplerAddr,DstAS", "Kafka list of fields to do hashing on (partition) separated by commas")
+	KafkaKeying = flag.String("kafka.key", "SamplerAddress,DstAS", "Kafka list of fields to do hashing on (partition) separated by commas")
 	KafkaVersion = flag.String("kafka.version", "0.11.0.0", "Log message version (must be a version that parses per sarama.ParseKafkaVersion)")
 }