From 2ce00474b77383b362692db8bfa6e5cb3c3019fa Mon Sep 17 00:00:00 2001
From: Travis Jeffery <tj@travisjeffery.com>
Date: Sun, 12 Feb 2017 19:17:17 -0500
Subject: [PATCH] add var for leader id

---
 broker/broker.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/broker/broker.go b/broker/broker.go
index 7aca3636..1c0e452d 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -284,11 +284,12 @@ func (b *Broker) CreateTopic(topic string, partitions int32) error {
 
 	for i := int32(0); i < partitions; i++ {
 		// TODO: need to know replica assignment here
+		leader := c[i%cLen].ID
 		partition := &jocko.Partition{
 			Topic:           topic,
 			ID:              i,
-			Leader:          c[i%cLen].ID,
-			PreferredLeader: c[i%cLen].ID,
+			Leader:          leader,
+			PreferredLeader: leader,
 			Replicas:        []int32{},
 		}
 		if err := b.AddPartition(partition); err != nil {