|
|
@@ -30,7 +30,7 @@ func init() {
|
|
|
flag.StringVar(&version, "version", "2.1.1", "Kafka cluster version")
|
|
|
flag.StringVar(&topics, "topics", "", "Kafka topics to be consumed, as a comma seperated list")
|
|
|
flag.StringVar(&assignor, "assignor", "range", "Consumer group partition assignment strategy (range, roundrobin, sticky)")
|
|
|
- flag.BoolVar(&oldest, "oldest", true, "Kafka consumer consume initial ofset from oldest")
|
|
|
+ flag.BoolVar(&oldest, "oldest", true, "Kafka consumer consume initial offset from oldest")
|
|
|
flag.BoolVar(&verbose, "verbose", false, "Sarama logging")
|
|
|
flag.Parse()
|
|
|
|
llussy