From 9cfe822b90f23ec4da6b0f6606e481fc755c4fb4 Mon Sep 17 00:00:00 2001 From: Todd Snyder Date: Thu, 9 Nov 2017 09:56:35 -0500 Subject: [PATCH] fixing issue #1 --- cmd/consumer/main.go | 1 + cmd/producer/main.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/cmd/consumer/main.go b/cmd/consumer/main.go index fe0262a..79ec6ba 100644 --- a/cmd/consumer/main.go +++ b/cmd/consumer/main.go @@ -19,6 +19,7 @@ var ( ) func main() { + kingpin.Parse() config := sarama.NewConfig() config.Consumer.Return.Errors = true brokers := *brokerList diff --git a/cmd/producer/main.go b/cmd/producer/main.go index 61c3286..cc7a2d1 100644 --- a/cmd/producer/main.go +++ b/cmd/producer/main.go @@ -14,7 +14,7 @@ var ( ) func main() { - + kingpin.Parse() config := sarama.NewConfig() config.Producer.RequiredAcks = sarama.WaitForAll config.Producer.Retry.Max = 5