From 19e71e4d8f5cdbabe18d8b2a3fd7dd55ccc03a7d Mon Sep 17 00:00:00 2001 From: Travis Jeffery Date: Mon, 18 Sep 2017 02:06:03 -0500 Subject: [PATCH] fix example --- examples/sarama/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/sarama/main.go b/examples/sarama/main.go index aa28ae64..9eaba5e3 100644 --- a/examples/sarama/main.go +++ b/examples/sarama/main.go @@ -143,7 +143,7 @@ func setup() func() { } // creating/deleting topic directly since Sarama doesn't support it - if err := store.CreateTopic(topic, numPartitions); err != nil && err != broker.ErrTopicExists { + if err := store.CreateTopic(topic, numPartitions, 1); err != nil && err != broker.ErrTopicExists { panic(err) }