Fix cli param default value - kafka.key

cloudflare · Mar 5, 2020 · 8067f51 · 8067f51
1 parent ef5ec28
commit 8067f51
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)")
 }