From 8067f51e9925a42ca651648e817a09efed5680e2 Mon Sep 17 00:00:00 2001 From: Shyam Sundar Date: Thu, 5 Mar 2020 14:13:17 +1100 Subject: [PATCH] Fix cli param default value - kafka.key --- transport/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/transport/kafka.go b/transport/kafka.go index ac364b6..085a937 100644 --- 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)") }