fix example

travisjeffery · Sep 18, 2017 · 19e71e4 · 19e71e4
1 parent baf2c05
commit 19e71e4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 	}